Struct TopicJoinRx

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

Implementations

impl<T> TopicJoinRx<T>

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

Finds RX by topic

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

Add a new input channel and return it

Trait Implementations

impl<T> Default for TopicJoinRx<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: Send + Sync> RxBundle for TopicJoinRx<T>

fn len(&self) -> usize

Number of channels

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

Name of the i-th endpoint

fn sync_all(&mut self, results: &mut [SyncResult])

Synchronizes all endpoints

fn check_connection(&self) -> ConnectionCheck

Connection status of all endpoints in the budle