pub struct BusLegReceiver<ChannelId, MSG, const STATIC_SIZE: usize> { /* private fields */ }Expand description
A receiver for a bus leg.
This struct is used to receive messages from a bus leg. It holds a queue of messages that have been sent to the bus leg.
Implementations§
Source§impl<ChannelId, MSG, const STATIC_SIZE: usize> BusLegReceiver<ChannelId, MSG, STATIC_SIZE>
impl<ChannelId, MSG, const STATIC_SIZE: usize> BusLegReceiver<ChannelId, MSG, STATIC_SIZE>
Sourcepub fn recv(&self) -> Option<(BusEventSource<ChannelId>, MSG)>
pub fn recv(&self) -> Option<(BusEventSource<ChannelId>, MSG)>
Receives a message from the bus leg.
§Returns
Returns Some((source, msg)) if there is a message in the queue, where source is the source of the bus event
and msg is the received message.
Returns None if the queue is empty.
pub fn set_awaker(&self, awaker: Arc<dyn Awaker>)
Auto Trait Implementations§
impl<ChannelId, MSG, const STATIC_SIZE: usize> Freeze for BusLegReceiver<ChannelId, MSG, STATIC_SIZE>
impl<ChannelId, MSG, const STATIC_SIZE: usize> !RefUnwindSafe for BusLegReceiver<ChannelId, MSG, STATIC_SIZE>
impl<ChannelId, MSG, const STATIC_SIZE: usize> Send for BusLegReceiver<ChannelId, MSG, STATIC_SIZE>
impl<ChannelId, MSG, const STATIC_SIZE: usize> Sync for BusLegReceiver<ChannelId, MSG, STATIC_SIZE>
impl<ChannelId, MSG, const STATIC_SIZE: usize> Unpin for BusLegReceiver<ChannelId, MSG, STATIC_SIZE>
impl<ChannelId, MSG, const STATIC_SIZE: usize> !UnwindSafe for BusLegReceiver<ChannelId, MSG, STATIC_SIZE>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more