aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--embassy/src/util/mpsc.rs30
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}