update pubsub example to use tokio 0.3.0

Author: dwrensha

capnp-rpc/examples/pubsub/Cargo.toml

@@ -16,8 +16,8 @@ capnpc = { path = "../../../capnpc" }
 [dependencies]
 capnp = { path = "../../../capnp" }
 futures = "0.3.0"
-tokio = { version = "0.2.0", features = ["net", "rt-util", "tcp", "macros"]}
-tokio-util = { version = "0.3.0", features = ["compat"] }
+tokio = { version = "0.3.0", features = ["net", "rt", "macros"]}
+tokio-util = { version = "0.4.0", features = ["compat"] }
 
 [dependencies.capnp-rpc]
 path = "../.."

capnp-rpc/examples/pubsub/main.rs

@@ -28,7 +28,7 @@ pub mod pubsub_capnp {
 pub mod client;
 pub mod server;
 
-#[tokio::main]
+#[tokio::main(flavor = "current_thread")]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let args: Vec<String> = ::std::env::args().collect();
     if args.len() >= 2 {

capnp-rpc/examples/pubsub/server.rs

@@ -112,7 +112,7 @@ pub async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let addr = args[2].to_socket_addrs().unwrap().next().expect("could not parse address");
 
     tokio::task::LocalSet::new().run_until(async move {
-        let mut listener = tokio::net::TcpListener::bind(&addr).await?;
+        let listener = tokio::net::TcpListener::bind(&addr).await?;
         let (publisher_impl, subscribers) = PublisherImpl::new();
         let publisher: publisher::Client<_> = capnp_rpc::new_client(publisher_impl);