aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDion Dokter <[email protected]>2022-06-16 13:51:35 +0200
committerDion Dokter <[email protected]>2022-06-16 13:51:35 +0200
commit98d0bb726c76c522e329e9a29f314e3d8c194b1d (patch)
treecc829df2394b482ea9a4230642d189ffbfc06bcd
parent36b363a5b71497d32d2968fcecf046773822c2e9 (diff)
fmt
-rw-r--r--embassy/src/channel/pubsub.rs3
1 files changed, 1 insertions, 2 deletions
diff --git a/embassy/src/channel/pubsub.rs b/embassy/src/channel/pubsub.rs
index 5d81431ec..577f7902b 100644
--- a/embassy/src/channel/pubsub.rs
+++ b/embassy/src/channel/pubsub.rs
@@ -316,8 +316,7 @@ impl<'a, T: Clone> futures::Stream for Subscriber<'a, T> {
316 // No, so we need to reregister our waker and sleep again 316 // No, so we need to reregister our waker and sleep again
317 None => { 317 None => {
318 unsafe { 318 unsafe {
319 this 319 this.channel
320 .channel
321 .register_subscriber_waker(this.subscriber_index, cx.waker()); 320 .register_subscriber_waker(this.subscriber_index, cx.waker());
322 } 321 }
323 Poll::Pending 322 Poll::Pending