Duplex-oriented API (#9)

carllerche · Dec 8, 2019 · dffa50b · dffa50b
1 parent ab9a63b
commit dffa50b
Show file tree

Hide file tree

Showing 3 changed files with 93 additions and 168 deletions.
diff --git a/examples/client.rs b/examples/client.rs
@@ -13,7 +13,8 @@ pub async fn main() {
     let length_delimited = FramedWrite::new(socket, LengthDelimitedCodec::new());
 
     // Serialize frames with JSON
-    let mut serialized = tokio_serde::FramedWrite::new(length_delimited, Json::default());
+    let mut serialized =
+        tokio_serde::SymmetricallyFramed::new(length_delimited, SymmetricalJson::default());
 
     // Send the value
     serialized

diff --git a/examples/server.rs b/examples/server.rs
@@ -18,8 +18,10 @@ pub async fn main() {
         let length_delimited = FramedRead::new(socket, LengthDelimitedCodec::new());
 
         // Deserialize frames
-        let mut deserialized =
-            tokio_serde::FramedRead::new(length_delimited, Json::<Value>::default());
+        let mut deserialized = tokio_serde::SymmetricallyFramed::new(
+            length_delimited,
+            SymmetricalJson::<Value>::default(),
+        );
 
         // Spawn a task that prints all received messages to STDOUT
         tokio::spawn(async move {