diff --git a/embassy/src/channel/pubsub.rs b/embassy/src/channel/pubsub.rs index 5d81431e..577f7902 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> { // 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