diff --git a/src/tee.rs b/src/tee.rs index e72bc8e..b921d03 100644 --- a/src/tee.rs +++ b/src/tee.rs @@ -116,16 +116,6 @@ impl Stream for Tee { } } - match Pin::new(&mut self.stream).poll_next(cx) { - Ready(Some(output)) => { - cx.waker().clone().wake(); - Ready(Some(output)) - } - Ready(None) => Ready(None), - Pending => { - cx.waker().clone().wake(); - Pending - } - } + Pin::new(&mut self.stream).poll_next(cx) } }