Apply code review suggestions

paritytech · Aug 28, 2023 · ca546cd · ca546cd
1 parent 096c0e0
commit ca546cd
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/substrate/client/network/sync/src/futures_stream.rs b/substrate/client/network/sync/src/futures_stream.rs
@@ -58,14 +58,14 @@ impl<F: Future> Stream for FuturesStream<F> {
 	type Item = <F as Future>::Output;
 
 	fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
-		if let Poll::Ready(Some(result)) = self.futures.poll_next_unpin(cx) {
-			Poll::Ready(Some(result))
-		} 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());
 
-			Poll::Pending
-		}
-	}
+            return Poll::Pending
+        };
+
+        Poll::Ready(Some(result))
+    }
 }
 
 #[cfg(test)]