Update to tokio 1.0 (#46)

* Update to tokio 1.0

* fix early data test

tokio-native-tls/Cargo.toml

@@ -23,11 +23,11 @@ categories = ["asynchronous", "network-programming"]
 
 [dependencies]
 native-tls = "0.2"
-tokio = "0.3"
+tokio = "1.0"
 
 [dev-dependencies]
-tokio = { version = "0.3.0", features = ["macros", "stream", "rt", "rt-multi-thread", "io-util", "net"] }
+tokio = { version = "1.0", features = ["macros", "rt", "rt-multi-thread", "io-util", "net"] }
-tokio-util = { version = "0.4.0", features = ["full"] }
+tokio-util = { version = "0.6.0", features = ["full"] }
 
 cfg-if = "0.1"
 env_logger = { version = "0.6", default-features = false }

tokio-rustls/Cargo.toml

@@ -12,7 +12,7 @@ categories = ["asynchronous", "cryptography", "network-programming"]
 edition = "2018"
 
 [dependencies]
-tokio = "0.3.5"
+tokio = "1.0"
 rustls = "0.19"
 webpki = "0.21"
 
@@ -21,7 +21,7 @@ early-data = []
 dangerous_configuration = ["rustls/dangerous_configuration"]
 
 [dev-dependencies]
-tokio = { version = "0.3.5", features = ["full"] }
+tokio = { version = "1.0", features = ["full"] }
 futures-util = "0.3.1"
 lazy_static = "1"
 webpki-roots = "0.21"

tokio-rustls/examples/client/Cargo.toml

@@ -5,7 +5,7 @@ authors = ["quininer <quininer@live.com>"]
 edition = "2018"
 
 [dependencies]
-tokio = { version = "0.3", features = [ "full" ] }
+tokio = { version = "1.0", features = [ "full" ] }
 argh = "0.1"
 tokio-rustls = { path = "../.." }
 webpki-roots = "0.21"

tokio-rustls/examples/server/Cargo.toml

@@ -5,6 +5,6 @@ authors = ["quininer <quininer@live.com>"]
 edition = "2018"
 
 [dependencies]
-tokio = { version = "0.3", features = [ "full" ] }
+tokio = { version = "1.0", features = [ "full" ] }
 argh = "0.1"
 tokio-rustls = { path = "../.." }

tokio-rustls/tests/badssl.rs

@@ -2,8 +2,8 @@ use rustls::ClientConfig;
 use std::io;
 use std::net::ToSocketAddrs;
 use std::sync::Arc;
+use tokio::io::{AsyncReadExt, AsyncWriteExt};
 use tokio::net::TcpStream;
-use tokio::prelude::*;
 use tokio_rustls::{client::TlsStream, TlsConnector};
 
 async fn get(

tokio-rustls/tests/early-data.rs

@@ -9,9 +9,8 @@ use std::process::{Child, Command, Stdio};
 use std::sync::Arc;
 use std::task::{Context, Poll};
 use std::time::Duration;
-use tokio::io::ReadBuf;
+use tokio::io::{AsyncRead, AsyncWriteExt, ReadBuf};
 use tokio::net::TcpStream;
-use tokio::prelude::*;
 use tokio::time::sleep;
 use tokio_rustls::{client::TlsStream, TlsConnector};
 
@@ -45,6 +44,7 @@ async fn send(
     //
     // see https://www.mail-archive.com/openssl-users@openssl.org/msg84451.html
     let sleep1 = sleep(Duration::from_secs(1));
+    futures_util::pin_mut!(sleep1);
     let mut stream = match future::select(Read1(stream), sleep1).await {
         future::Either::Right((_, Read1(stream))) => stream,
         future::Either::Left((Err(err), _)) => return Err(err),

tokio-rustls/tests/test.rs

@@ -7,9 +7,8 @@ use std::net::SocketAddr;
 use std::sync::mpsc::channel;
 use std::sync::Arc;
 use std::{io, thread};
-use tokio::io::{copy, split};
+use tokio::io::{copy, split, AsyncReadExt, AsyncWriteExt};
 use tokio::net::{TcpListener, TcpStream};
-use tokio::prelude::*;
 use tokio::runtime;
 use tokio_rustls::{TlsAcceptor, TlsConnector};