@@ -6,6 +6,7 @@ extern crate futures_timer;
66extern crate net2;
77extern crate tokio;
88extern crate tokio_io;
9+ extern crate tokio_tcp;
910extern crate pretty_env_logger;
1011
1112use std:: io:: { Read , Write } ;
@@ -18,7 +19,7 @@ use hyper::{Body, Client, Method, Request, StatusCode};
1819use futures:: { Future , Stream } ;
1920use futures:: sync:: oneshot;
2021use tokio:: runtime:: current_thread:: Runtime ;
21- use tokio :: net :: tcp :: { ConnectFuture , TcpListener as TkTcpListener , TcpStream } ;
22+ use tokio_tcp :: { ConnectFuture , TcpListener as TkTcpListener , TcpStream } ;
2223
2324fn s ( buf : & [ u8 ] ) -> & str {
2425 :: std:: str:: from_utf8 ( buf) . expect ( "from_utf8" )
@@ -713,7 +714,7 @@ mod dispatch_impl {
713714 use futures:: { self , Future } ;
714715 use futures:: sync:: { mpsc, oneshot} ;
715716 use futures_timer:: Delay ;
716- use tokio :: net :: TcpStream ;
717+ use tokio_tcp :: TcpStream ;
717718 use tokio:: runtime:: current_thread:: Runtime ;
718719 use tokio_io:: { AsyncRead , AsyncWrite } ;
719720
@@ -1578,7 +1579,7 @@ mod conn {
15781579 use futures:: sync:: oneshot;
15791580 use futures_timer:: Delay ;
15801581 use tokio:: runtime:: current_thread:: Runtime ;
1581- use tokio :: net :: TcpStream ;
1582+ use tokio_tcp :: TcpStream ;
15821583 use tokio_io:: { AsyncRead , AsyncWrite } ;
15831584
15841585 use hyper:: { self , Request , Body , Method } ;
0 commit comments