Struct TopicChannel 

pub struct TopicChannel { /* private fields */ }

Topic-based channel

Implementations

impl TopicChannel

pub fn new(topic: String, config: ChannelConfig) -> Self

Create a new topic channel

pub fn topic(&self) -> &str

Get topic name

pub async fn stats(&self) -> ChannelStats

Get statistics

Trait Implementations

impl Channel for TopicChannel

async fn subscribe(&self, subscriber: ConnectionId) -> Result<()>

Subscribe to the channel

async fn unsubscribe(&self, subscriber: &ConnectionId) -> Result<()>

Unsubscribe from the channel

async fn publish(&self, message: Message) -> Result<usize>

Publish a message to the channel

async fn subscriber_count(&self) -> usize

Get subscriber count