Struct TopicSplitTx

pub struct TopicSplitTx<T> { /* private fields */ }

Implementations

impl<T> TopicSplitTx<T>

pub fn find_by_topic( &mut self, needle: &Topic, ) -> Option<&mut DoubleBufferTx<T>>

Finds TX by topic

pub fn add(&mut self, topic: Topic) -> &mut DoubleBufferTx<T>

Add a new input channel and return it

Trait Implementations

impl<T> Default for TopicSplitTx<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: Send + Sync + Clone> TxBundle for TopicSplitTx<T>

fn channel_count(&self) -> usize

Number of channels

fn name(&self, index: usize) -> &str

Name of the i-th endpoint

fn outbox_message_count(&self, index: usize) -> usize

Number of messages currently available on the i-th endpoint

fn flush_all(&mut self, result: &mut [FlushResult])

Flushes all endpoints

fn check_connection(&self) -> ConnectionCheck

Connection status of all endpoints in the budle

fn iter_names(&self) -> impl Iterator<Item = &str>

Iterate over all channel names