max/embassy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

embassy/channel: remove unused receiver_consumed

Browse Source
This commit is contained in:
Dario Nieuwenhuis 2021-09-11 02:58:41 +02:00
parent b78f4695c4
commit e1f9dd1170
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
embassy/src/channel/mpsc.rs
View File

@ -39,7 +39,6 @@
use core::cell::UnsafeCell; use core::cell::UnsafeCell;
use core::fmt; use core::fmt;
use core::marker::PhantomData;
use core::pin::Pin; use core::pin::Pin;
use core::task::Context; use core::task::Context;
use core::task::Poll; use core::task::Poll;
@ -75,7 +74,6 @@ where
M: Mutex<Data = ()>, M: Mutex<Data = ()>,
{ {
channel_cell: &'ch UnsafeCell<ChannelCell<M, T, N>>, channel_cell: &'ch UnsafeCell<ChannelCell<M, T, N>>,
_receiver_consumed: &'ch mut PhantomData<()>,
} }
// Safe to pass the receiver around // Safe to pass the receiver around
@ -123,7 +121,6 @@ where
}; };
let receiver = Receiver { let receiver = Receiver {
channel_cell: &channel.channel_cell, channel_cell: &channel.channel_cell,
_receiver_consumed: &mut channel.receiver_consumed,
}; };
Channel::lock(&channel.channel_cell, |c| { Channel::lock(&channel.channel_cell, |c| {
c.register_receiver(); c.register_receiver();
@ -587,7 +584,6 @@ where
M: Mutex<Data = ()>, M: Mutex<Data = ()>,
{ {
channel_cell: UnsafeCell<ChannelCell<M, T, N>>, channel_cell: UnsafeCell<ChannelCell<M, T, N>>,
receiver_consumed: PhantomData<()>,
} }
struct ChannelCell<M, T, const N: usize> struct ChannelCell<M, T, const N: usize>
@ -625,7 +621,6 @@ where
let channel_cell = ChannelCell { mutex, state }; let channel_cell = ChannelCell { mutex, state };
Channel { Channel {
channel_cell: UnsafeCell::new(channel_cell), channel_cell: UnsafeCell::new(channel_cell),
receiver_consumed: PhantomData,
} }
} }