diff options
| author | Dion Dokter <[email protected]> | 2022-06-16 13:51:35 +0200 |
|---|---|---|
| committer | Dion Dokter <[email protected]> | 2022-06-16 13:51:35 +0200 |
| commit | 98d0bb726c76c522e329e9a29f314e3d8c194b1d (patch) | |
| tree | cc829df2394b482ea9a4230642d189ffbfc06bcd | |
| parent | 36b363a5b71497d32d2968fcecf046773822c2e9 (diff) | |
fmt
| -rw-r--r-- | embassy/src/channel/pubsub.rs | 3 |
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 |
