diff options
Diffstat (limited to 'crates/utils/tcp_connection/tcp_connection_test/src')
| -rw-r--r-- | crates/utils/tcp_connection/tcp_connection_test/src/example_handle.rs | 21 |
1 files changed, 15 insertions, 6 deletions
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; + } } } |
