async client: save latest Waker (#1198)

paritytech · Sep 8, 2023 · c3d367d · c3d367d
1 parent 9b0d4f3
commit c3d367d
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/core/src/client/async_client/mod.rs b/core/src/client/async_client/mod.rs
@@ -931,8 +931,7 @@ impl<Fut: Future> Stream for MaybePendingFutures<Fut> {
 
 	fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
 		if self.futs.is_empty() {
-			self.waker.get_or_insert_with(|| cx.waker().clone());
-
+			self.waker = Some(cx.waker().clone());
 			return Poll::Pending;
 		}