Trait simple_pubsub::Topic

pub trait Topic<T>: Clone + Send + Sync + 'static {
    fn subscribe(self, name: impl Into<String>) -> (u32, Receiver<Arc<T>>);
    fn unsubscribe(self, name: impl AsRef<str>, id: u32) -> Option<u32>;
    fn publish(self, name: impl Into<String>, value: Arc<T>);
}

Required methods

fn subscribe(self, name: impl Into<String>) -> (u32, Receiver<Arc<T>>)

subscribe to a topic (here name should be session id)

fn unsubscribe(self, name: impl AsRef<str>, id: u32) -> Option<u32>

unsubscribe to a topic

fn publish(self, name: impl Into<String>, value: Arc<T>)

public a message to a topic

Implementations on Foreign Types

impl<T> Topic<T> for Arc<Broadcaster<T>> where
    T: Debug + Send + Sync + 'static, 

fn subscribe(self, name: impl Into<String>) -> (u32, Receiver<Arc<T>>)

fn unsubscribe(self, name: impl AsRef<str>, id: u32) -> Option<u32>

fn publish(self, name: impl Into<String>, value: Arc<T>)

Implementors