diff --git a/src/net/tcp.rs b/src/net/tcp.rs index b20f18ec7..a0d441244 100644 --- a/src/net/tcp.rs +++ b/src/net/tcp.rs @@ -526,7 +526,7 @@ impl<'a> AsyncRead for &'a TcpStream { } Err(e) => { if e.kind() == io::ErrorKind::WouldBlock { - self.io.need_write(); + self.io.need_read(); } Err(e) }