Struct PubSub

pub struct PubSub { /* private fields */ }

Implementations

impl PubSub

pub fn instance() -> Arc<PubSub>

pub fn create_publisher(&self, topic: &str) -> usize

pub fn subscribe_manual<T>( &self, topic: &str, config: TopicConfig, ) -> ManualReceiver<T>

where T: 'static + Send + Sync + Clone,

pub fn subscribe<T, F>( &self, topic: &str, config: TopicConfig, callback: F, ) -> String

where T: Send + Sync + Clone + 'static, F: Fn(&T) + Send + Sync + 'static,

pub fn try_publish<T: Send + Sync + Clone + 'static>( &self, topic_id: usize, message: T, )

pub fn publish<T: Send + Sync + Clone + 'static>( &self, topic_id: usize, message: T, )

pub fn publish_with_timeout<T: Send + Sync + Clone + 'static>( &self, topic_id: usize, message: T, max_wait_ms: Option<u64>, )

pub fn unsubscribe(&self, subscriber_id: &str)