Struct TopicSplitTx

pub struct TopicSplitTx<T> {
    pub channels: Vec<(Topic, DoubleBufferTx<T>)>,
}

Fields

channels: Vec<(Topic, DoubleBufferTx<T>)>

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 len(&self) -> usize

Number of channels

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

Name of 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