Improved examples

examples/client.rs

@@ -6,9 +6,9 @@ struct Data;
 
 impl Method for Data {
     const NAME: &'static str = "data";
-    type Request = ();
+    type Request = String;
-    type Response = ();
+    type Response = String;
-    type Error = ();
+    type Error = String;
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -17,15 +17,19 @@ async fn main() -> session_rs::Result<()> {
 
     session.start_receiver();
 
-    println!("{:?}", session.request::<Data>(()).await?);
+    println!(
-
+        "Hi: {:?}",
         session
-        .on::<Data, _>(async |i, d| {
+            .request::<Data>("Hello from client".to_string())
-            println!("Ok {i} {d:?}");
+            .await?
+    );
 
-            Ok(())
+    println!(
-        })
+        "Invalid data response: {:?}",
-        .await;
+        session
+            .request::<Data>("invalid_data".to_string())
+            .await?
+    );
 
     tokio::time::sleep(tokio::time::Duration::from_millis(1000)).await;
 

examples/server.rs

@@ -8,9 +8,9 @@ struct Data;
 
 impl Method for Data {
     const NAME: &'static str = "data";
-    type Request = ();
+    type Request = String;
-    type Response = ();
+    type Response = String;
-    type Error = ();
+    type Error = String;
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -32,7 +32,17 @@ async fn main() -> session_rs::Result<()> {
 
             session.start_receiver();
 
-            session.on::<Data, _>(async |_, _| Ok(())).await;
+            session
+                .on::<Data, _>(async |_, req| {
+                    println!("Msg from client: {req}");
+
+                    if req == "invalid_data" {
+                        return Err("Invalid data".to_string());
+                    }
+
+                    Ok("Hello from server".to_string())
+                })
+                .await;
         });
     }
 }