From 8b28bcefa5225b17e3aadda743383dc22f3f3ec3 Mon Sep 17 00:00:00 2001 From: 魏曹先生 <1992414357@qq.com> Date: Mon, 22 Sep 2025 19:04:59 +0800 Subject: Remove redundant Sync bound from process future --- .../tcp_connection/tcp_connection_test/src/test_challenge.rs | 8 ++------ .../tcp_connection/tcp_connection_test/src/test_connection.rs | 8 ++------ .../tcp_connection/tcp_connection_test/src/test_file_transfer.rs | 8 ++------ 3 files changed, 6 insertions(+), 18 deletions(-) (limited to 'crates/utils/tcp_connection/tcp_connection_test') 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 for ExampleChallengeClientHandle { - fn process( - mut instance: ConnectionInstance, - ) -> impl std::future::Future + Send + Sync { + fn process(mut instance: ConnectionInstance) -> impl std::future::Future + Send { async move { // Accept challenge with correct key let key = current_dir() @@ -69,9 +67,7 @@ impl ClientHandle for ExampleChallengeClientHandle pub(crate) struct ExampleChallengeServerHandle; impl ServerHandle for ExampleChallengeServerHandle { - fn process( - mut instance: ConnectionInstance, - ) -> impl std::future::Future + Send + Sync { + fn process(mut instance: ConnectionInstance) -> impl std::future::Future + 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 for ExampleClientHandle { - fn process( - mut instance: ConnectionInstance, - ) -> impl std::future::Future + Send + Sync { + fn process(mut instance: ConnectionInstance) -> impl std::future::Future + Send { async move { // Write name let Ok(_) = instance.write_text("Peter").await else { @@ -31,9 +29,7 @@ impl ClientHandle for ExampleClientHandle { pub(crate) struct ExampleServerHandle; impl ServerHandle for ExampleServerHandle { - fn process( - mut instance: ConnectionInstance, - ) -> impl std::future::Future + Send + Sync { + fn process(mut instance: ConnectionInstance) -> impl std::future::Future + 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 for ExampleFileTransferClientHandle { - fn process( - mut instance: ConnectionInstance, - ) -> impl std::future::Future + Send + Sync { + fn process(mut instance: ConnectionInstance) -> impl std::future::Future + Send { async move { let image_path = current_dir() .unwrap() @@ -31,9 +29,7 @@ impl ClientHandle for ExampleFileTransferClient pub(crate) struct ExampleFileTransferServerHandle; impl ServerHandle for ExampleFileTransferServerHandle { - fn process( - mut instance: ConnectionInstance, - ) -> impl std::future::Future + Send + Sync { + fn process(mut instance: ConnectionInstance) -> impl std::future::Future + Send { async move { let save_path = current_dir() .unwrap() -- cgit