Struct PushClient 

pub struct PushClient<C: ChannelKind> { /* private fields */ }

Generic multiplexed push client.

Parameterized by C: ChannelKind — the consumer defines their own channel taxonomy. Register handlers with on, then call connect to start receiving frames.

Implementations

impl<C: ChannelKind> PushClient<C>

pub fn new(config: ClientConfig) -> Self

pub fn on(&mut self, channel: C, receiver: impl ChannelReceiver<C>)

Register a handler for a channel. Must be called before connect().

pub async fn connect(&mut self) -> Result<(), ConnectError>

Connect to the server. Performs auth handshake and starts the receive loop.

pub async fn send(&self, frame: Frame<C>) -> Result<(), SendError>

Send a frame to the server (client → server).

pub async fn subscribe(&self, channels: &[C]) -> Result<(), SendError>

Subscribe to additional channels after connect.

pub async fn unsubscribe(&self, channels: &[C]) -> Result<(), SendError>

Unsubscribe from channels.

pub async fn disconnect(&mut self) -> Result<(), SendError>

Graceful disconnect.

pub fn state(&self) -> ConnectionState

Current connection state.

pub fn cursors(&self) -> HashMap<C, u64>

Per-channel cursor values (for diagnostics / resume).