We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent da0c28c commit dbbd00cCopy full SHA for dbbd00c
src/utils/channel.rs
@@ -30,7 +30,10 @@ impl<T> Stream for LocalReceiver<T> {
30
if channel.closed {
31
Poll::Ready(None)
32
} else {
33
- channel.waker = Some(cx.waker().clone());
+ match &mut channel.waker {
34
+ Some(prev) => prev.clone_from(cx.waker()),
35
+ None => channel.waker = Some(cx.waker().clone())
36
+ }
37
Poll::Pending
38
}
39
0 commit comments