diff options
| -rw-r--r-- | embassy/src/util/mpsc.rs | 30 |
1 files changed, 10 insertions, 20 deletions
diff --git a/embassy/src/util/mpsc.rs b/embassy/src/util/mpsc.rs index 580c6794f..68fcdf7f9 100644 --- a/embassy/src/util/mpsc.rs +++ b/embassy/src/util/mpsc.rs | |||
| @@ -403,27 +403,17 @@ impl<T, const N: usize> ChannelState<T, N> { | |||
| 403 | const INIT: MaybeUninit<UnsafeCell<T>> = MaybeUninit::uninit(); | 403 | const INIT: MaybeUninit<UnsafeCell<T>> = MaybeUninit::uninit(); |
| 404 | 404 | ||
| 405 | const fn new() -> Self { | 405 | const fn new() -> Self { |
| 406 | let buf = [Self::INIT; N]; | ||
| 407 | let read_pos = 0; | ||
| 408 | let write_pos = 0; | ||
| 409 | let full = false; | ||
| 410 | let closing = false; | ||
| 411 | let closed = false; | ||
| 412 | let receiver_registered = false; | ||
| 413 | let senders_registered = 0; | ||
| 414 | let receiver_waker = WakerRegistration::new(); | ||
| 415 | let senders_waker = WakerRegistration::new(); | ||
| 416 | ChannelState { | 406 | ChannelState { |
| 417 | buf, | 407 | buf: [Self::INIT; N], |
| 418 | read_pos, | 408 | read_pos: 0, |
| 419 | write_pos, | 409 | write_pos: 0, |
| 420 | full, | 410 | full: false, |
| 421 | closing, | 411 | closing: false, |
| 422 | closed, | 412 | closed: false, |
| 423 | receiver_registered, | 413 | receiver_registered: false, |
| 424 | senders_registered, | 414 | senders_registered: 0, |
| 425 | receiver_waker, | 415 | receiver_waker: WakerRegistration::new(), |
| 426 | senders_waker, | 416 | senders_waker: WakerRegistration::new(), |
| 427 | } | 417 | } |
| 428 | } | 418 | } |
| 429 | } | 419 | } |
