diff --git a/src/net/tcp.rs b/src/net/tcp.rs index 9d71dcd..42580c4 100644 --- a/src/net/tcp.rs +++ b/src/net/tcp.rs @@ -6,6 +6,7 @@ use std::task::{Context, Poll}; use cfg_if::cfg_if; use futures::{prelude::*, ready}; +use futures::stream::FusedStream; use crate::net::driver::IoHandle; @@ -667,6 +668,10 @@ impl<'a> Stream for Incoming<'a> { } } +impl<'a> FusedStream for Incoming<'a> { + fn is_terminated(&self) -> bool { false } +} + impl From for TcpStream { /// Converts a `std::net::TcpStream` into its asynchronous equivalent. fn from(stream: net::TcpStream) -> TcpStream {