diff --git a/substrate/client/network/sync/src/futures_stream.rs b/substrate/client/network/sync/src/futures_stream.rs index 253d59c09b4c..c33d582345b6 100644 --- a/substrate/client/network/sync/src/futures_stream.rs +++ b/substrate/client/network/sync/src/futures_stream.rs @@ -58,14 +58,14 @@ impl Stream for FuturesStream { type Item = ::Output; fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll> { - let Poll::Ready(Some(result)) = self.futures.poll_next_unpin(cx) else { - self.waker = Some(cx.waker().clone()); + let Poll::Ready(Some(result)) = self.futures.poll_next_unpin(cx) else { + self.waker = Some(cx.waker().clone()); - return Poll::Pending - }; + return Poll::Pending + }; - Poll::Ready(Some(result)) - } + Poll::Ready(Some(result)) + } } #[cfg(test)]