This commit is contained in:
Dion Dokter 2022-06-16 13:51:35 +02:00
parent 36b363a5b7
commit 98d0bb726c

View File

@ -316,8 +316,7 @@ impl<'a, T: Clone> futures::Stream for Subscriber<'a, T> {
// No, so we need to reregister our waker and sleep again
None => {
unsafe {
this
.channel
this.channel
.register_subscriber_waker(this.subscriber_index, cx.waker());
}
Poll::Pending