Struct Channel 

pub struct Channel {
    pub name: String,
    /* private fields */
}

Represents a named realtime channel with broadcast capabilities.

Fields

name: String

Channel identifier name.

Implementations

impl Channel

pub fn new(name: impl Into<String>, capacity: usize) -> Self

Creates a new realtime channel with specified message queue capacity.

pub fn broadcast( &self, event: &str, payload: &str, ) -> Result<usize, RealtimeError>

Broadcasts an event and payload to all subscribed clients.

pub fn subscribe(&self) -> Receiver<RealtimeMessage>

Subscribes to messages broadcasted on this channel.