diff --git a/p2p/async-buffer/src/lib.rs b/p2p/async-buffer/src/lib.rs index de38cc9e..4930a309 100644 --- a/p2p/async-buffer/src/lib.rs +++ b/p2p/async-buffer/src/lib.rs @@ -78,7 +78,7 @@ impl<T> Stream for BufferStream<T> { // wake the sink. self.sink_waker.wake(); - return Poll::Ready(Some(item)); + Poll::Ready(Some(item)) } }