diff options
| author | 魏曹先生 <1992414357@qq.com> | 2025-09-22 19:04:59 +0800 |
|---|---|---|
| committer | 魏曹先生 <1992414357@qq.com> | 2025-09-22 19:04:59 +0800 |
| commit | 8b28bcefa5225b17e3aadda743383dc22f3f3ec3 (patch) | |
| tree | 1c314e8540a036e02faed9afe2d8e18f1291885e /crates/utils/tcp_connection/tcp_connection_test | |
| parent | a759bf0c040cdfd0fa207133cbd8629d8be51334 (diff) | |
Remove redundant Sync bound from process future
Diffstat (limited to 'crates/utils/tcp_connection/tcp_connection_test')
3 files changed, 6 insertions, 18 deletions
diff --git a/crates/utils/tcp_connection/tcp_connection_test/src/test_challenge.rs b/crates/utils/tcp_connection/tcp_connection_test/src/test_challenge.rs index 05e47ad..0ca8540 100644 --- a/crates/utils/tcp_connection/tcp_connection_test/src/test_challenge.rs +++ b/crates/utils/tcp_connection/tcp_connection_test/src/test_challenge.rs @@ -14,9 +14,7 @@ use tokio::{ pub(crate) struct ExampleChallengeClientHandle; impl ClientHandle<ExampleChallengeServerHandle> for ExampleChallengeClientHandle { - fn process( - mut instance: ConnectionInstance, - ) -> impl std::future::Future<Output = ()> + Send + Sync { + fn process(mut instance: ConnectionInstance) -> impl std::future::Future<Output = ()> + Send { async move { // Accept challenge with correct key let key = current_dir() @@ -69,9 +67,7 @@ impl ClientHandle<ExampleChallengeServerHandle> for ExampleChallengeClientHandle pub(crate) struct ExampleChallengeServerHandle; impl ServerHandle<ExampleChallengeClientHandle> for ExampleChallengeServerHandle { - fn process( - mut instance: ConnectionInstance, - ) -> impl std::future::Future<Output = ()> + Send + Sync { + fn process(mut instance: ConnectionInstance) -> impl std::future::Future<Output = ()> + Send { async move { // Challenge with correct key let key_dir = current_dir().unwrap().join("res").join("key"); diff --git a/crates/utils/tcp_connection/tcp_connection_test/src/test_connection.rs b/crates/utils/tcp_connection/tcp_connection_test/src/test_connection.rs index bbea92f..6238c39 100644 --- a/crates/utils/tcp_connection/tcp_connection_test/src/test_connection.rs +++ b/crates/utils/tcp_connection/tcp_connection_test/src/test_connection.rs @@ -11,9 +11,7 @@ use tokio::{join, time::sleep}; pub(crate) struct ExampleClientHandle; impl ClientHandle<ExampleServerHandle> for ExampleClientHandle { - fn process( - mut instance: ConnectionInstance, - ) -> impl std::future::Future<Output = ()> + Send + Sync { + fn process(mut instance: ConnectionInstance) -> impl std::future::Future<Output = ()> + Send { async move { // Write name let Ok(_) = instance.write_text("Peter").await else { @@ -31,9 +29,7 @@ impl ClientHandle<ExampleServerHandle> for ExampleClientHandle { pub(crate) struct ExampleServerHandle; impl ServerHandle<ExampleClientHandle> for ExampleServerHandle { - fn process( - mut instance: ConnectionInstance, - ) -> impl std::future::Future<Output = ()> + Send + Sync { + fn process(mut instance: ConnectionInstance) -> impl std::future::Future<Output = ()> + Send { async move { // Read name let Ok(name) = instance.read_text().await else { diff --git a/crates/utils/tcp_connection/tcp_connection_test/src/test_file_transfer.rs b/crates/utils/tcp_connection/tcp_connection_test/src/test_file_transfer.rs index 94b77c4..d316080 100644 --- a/crates/utils/tcp_connection/tcp_connection_test/src/test_file_transfer.rs +++ b/crates/utils/tcp_connection/tcp_connection_test/src/test_file_transfer.rs @@ -14,9 +14,7 @@ use tokio::{ pub(crate) struct ExampleFileTransferClientHandle; impl ClientHandle<ExampleFileTransferServerHandle> for ExampleFileTransferClientHandle { - fn process( - mut instance: ConnectionInstance, - ) -> impl std::future::Future<Output = ()> + Send + Sync { + fn process(mut instance: ConnectionInstance) -> impl std::future::Future<Output = ()> + Send { async move { let image_path = current_dir() .unwrap() @@ -31,9 +29,7 @@ impl ClientHandle<ExampleFileTransferServerHandle> for ExampleFileTransferClient pub(crate) struct ExampleFileTransferServerHandle; impl ServerHandle<ExampleFileTransferClientHandle> for ExampleFileTransferServerHandle { - fn process( - mut instance: ConnectionInstance, - ) -> impl std::future::Future<Output = ()> + Send + Sync { + fn process(mut instance: ConnectionInstance) -> impl std::future::Future<Output = ()> + Send { async move { let save_path = current_dir() .unwrap() |
