From 15832a893383a850c9d032ab1620661b0121f247 Mon Sep 17 00:00:00 2001
From: 魏曹先生 <1992414357@qq.com>
Date: Wed, 17 Sep 2025 12:44:48 +0800
Subject: Update examples

---
 .../tcp_connection_test/src/example_handle.rs       | 21 +++++++++++++++------
 1 file changed, 15 insertions(+), 6 deletions(-)

(limited to 'crates/utils/tcp_connection/tcp_connection_test/src')

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;
+        }
     }
 }
-- 
cgit