diff options
| -rw-r--r-- | crates/utils/tcp_connection/tcp_connection_test/Cargo.toml | 4 | ||||
| -rw-r--r-- | crates/utils/tcp_connection/tcp_connection_test/src/example_handle.rs | 21 |
2 files changed, 17 insertions, 8 deletions
diff --git a/crates/utils/tcp_connection/tcp_connection_test/Cargo.toml b/crates/utils/tcp_connection/tcp_connection_test/Cargo.toml index 54065ad..e4cba71 100644 --- a/crates/utils/tcp_connection/tcp_connection_test/Cargo.toml +++ b/crates/utils/tcp_connection/tcp_connection_test/Cargo.toml @@ -4,5 +4,5 @@ edition = "2024" version.workspace = true [dependencies] -tcp_connection = { path="../../tcp_connection" } -tokio = { version = "1.46.1", features = ["full"] }
\ No newline at end of file +tcp_connection = { path = "../../tcp_connection" } +tokio = { version = "1.46.1", features = ["full"] } diff --git a/crates/utils/tcp_connection/tcp_connection_test/src/example_handle.rs b/crates/utils/tcp_connection/tcp_connection_test/src/example_handle.rs index 2c84bd1..1f02133 100644 --- a/crates/utils/tcp_connection/tcp_connection_test/src/example_handle.rs +++ b/crates/utils/tcp_connection/tcp_connection_test/src/example_handle.rs @@ -7,10 +7,15 @@ pub(crate) struct ExampleClientHandle; impl ClientHandle<ExampleServerHandle> for ExampleClientHandle { fn process( - instance: ConnectionInstance, + mut instance: ConnectionInstance, ) -> impl std::future::Future<Output = ()> + Send + Sync { - let _ = instance; - async {} + async move { + let _ = instance.write_text("Hello, World!").await; + let Ok(result) = instance.read_text(512 as u32).await else { + return; + }; + println!("Received: `{}`", result); + } } } @@ -18,9 +23,13 @@ pub(crate) struct ExampleServerHandle; impl ServerHandle<ExampleClientHandle> for ExampleServerHandle { fn process( - instance: ConnectionInstance, + mut instance: ConnectionInstance, ) -> impl std::future::Future<Output = ()> + Send + Sync { - let _ = instance; - async {} + async move { + let Ok(_) = instance.read_text(512 as u32).await else { + return; + }; + let _ = instance.write_text("Hello!").await; + } } } |