pub struct MultiplexerRx<T> { /* private fields */ }Implementations§
Source§impl<T> MultiplexerRx<T>
impl<T> MultiplexerRx<T>
pub fn new(count: usize) -> Self
Sourcepub fn selection_mut(&mut self) -> &mut MessageRx<MultiplexerSelection>
pub fn selection_mut(&mut self) -> &mut MessageRx<MultiplexerSelection>
Gets the selection channel
Sourcepub fn channel_mut(&mut self, index: usize) -> &mut MessageRx<T>
pub fn channel_mut(&mut self, index: usize) -> &mut MessageRx<T>
Get the i-th input channel
Sourcepub fn new_channel_mut(&mut self) -> &mut MessageRx<T>
pub fn new_channel_mut(&mut self) -> &mut MessageRx<T>
Add a new input channel and return it
Trait Implementations§
Source§impl<T: Send + Sync> RxBundle for MultiplexerRx<T>
impl<T: Send + Sync> RxBundle for MultiplexerRx<T>
Source§fn channel_count(&self) -> usize
fn channel_count(&self) -> usize
Number of channels
Source§fn inbox_message_count(&self, index: usize) -> usize
fn inbox_message_count(&self, index: usize) -> usize
Number of messages currently available on the i-th endpoint
Source§fn sync_all(&mut self, results: &mut [SyncResult])
fn sync_all(&mut self, results: &mut [SyncResult])
Synchronizes all endpoints
Source§fn check_connection(&self) -> ConnectionCheck
fn check_connection(&self) -> ConnectionCheck
Connection status of all endpoints in the budle
Source§fn iter_names(&self) -> impl Iterator<Item = &str>
fn iter_names(&self) -> impl Iterator<Item = &str>
Iterate over all channel names
Auto Trait Implementations§
impl<T> Freeze for MultiplexerRx<T>
impl<T> RefUnwindSafe for MultiplexerRx<T>where
T: RefUnwindSafe,
impl<T> Send for MultiplexerRx<T>
impl<T> Sync for MultiplexerRx<T>
impl<T> Unpin for MultiplexerRx<T>where
T: Unpin,
impl<T> UnwindSafe for MultiplexerRx<T>where
T: UnwindSafe,
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