update RPC examples to use buffered IO

Author: dwrensha

capnp-rpc/examples/calculator/client.rs

@@ -67,8 +67,8 @@ async fn try_main(args: Vec<String>) -> Result<(), Box<dyn std::error::Error>> {
     let (reader, writer) = tokio_util::compat::TokioAsyncReadCompatExt::compat(stream).split();
 
     let network = Box::new(twoparty::VatNetwork::new(
-        reader,
-        writer,
+        futures::io::BufReader::new(reader),
+        futures::io::BufWriter::new(writer),
         rpc_twoparty_capnp::Side::Client,
         Default::default(),
     ));

capnp-rpc/examples/calculator/server.rs

@@ -225,8 +225,8 @@ pub async fn main() -> Result<(), Box<dyn std::error::Error>> {
                 let (reader, writer) =
                     tokio_util::compat::TokioAsyncReadCompatExt::compat(stream).split();
                 let network = twoparty::VatNetwork::new(
-                    reader,
-                    writer,
+                    futures::io::BufReader::new(reader),
+                    futures::io::BufWriter::new(writer),
                     rpc_twoparty_capnp::Side::Server,
                     Default::default(),
                 );

capnp-rpc/examples/hello-world/client.rs

@@ -46,8 +46,8 @@ pub async fn main() -> Result<(), Box<dyn std::error::Error>> {
             let (reader, writer) =
                 tokio_util::compat::TokioAsyncReadCompatExt::compat(stream).split();
             let rpc_network = Box::new(twoparty::VatNetwork::new(
-                reader,
-                writer,
+                futures::io::BufReader::new(reader),
+                futures::io::BufWriter::new(writer),
                 rpc_twoparty_capnp::Side::Client,
                 Default::default(),
             ));

capnp-rpc/examples/hello-world/server.rs

@@ -67,8 +67,8 @@ pub async fn main() -> Result<(), Box<dyn std::error::Error>> {
                 let (reader, writer) =
                     tokio_util::compat::TokioAsyncReadCompatExt::compat(stream).split();
                 let network = twoparty::VatNetwork::new(
-                    reader,
-                    writer,
+                    futures::io::BufReader::new(reader),
+                    futures::io::BufWriter::new(writer),
                     rpc_twoparty_capnp::Side::Server,
                     Default::default(),
                 );

capnp-rpc/examples/pubsub/client.rs

@@ -61,8 +61,8 @@ pub async fn main() -> Result<(), Box<dyn std::error::Error>> {
             let (reader, writer) =
                 tokio_util::compat::TokioAsyncReadCompatExt::compat(stream).split();
             let rpc_network = Box::new(twoparty::VatNetwork::new(
-                reader,
-                writer,
+                futures::io::BufReader::new(reader),
+                futures::io::BufWriter::new(writer),
                 rpc_twoparty_capnp::Side::Client,
                 Default::default(),
             ));

capnp-rpc/examples/pubsub/server.rs

@@ -138,8 +138,8 @@ pub async fn main() -> Result<(), Box<dyn std::error::Error>> {
                     let (reader, writer) =
                         tokio_util::compat::TokioAsyncReadCompatExt::compat(stream).split();
                     let network = twoparty::VatNetwork::new(
-                        reader,
-                        writer,
+                        futures::io::BufReader::new(reader),
+                        futures::io::BufWriter::new(writer),
                         rpc_twoparty_capnp::Side::Server,
                         Default::default(),
                     );