Struct PushServer 

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

Generic multiplexed push server parameterized by channel type.

C implements ChannelKind and defines the channel taxonomy. Channel-specific handling is registered by the consumer via register_handler.

Implementations

impl<C: ChannelKind> PushServer<C>

pub fn new() -> Self

pub fn with_auth_validator(auth_validator: AuthValidator<C>) -> Self

pub fn router(self: Arc<Self>) -> Router<Arc<Self>>

Axum router exposing /rps (WebSocket), /rps/sse, and /rps/ack.

pub fn connected_clients(&self) -> usize

Number of currently connected WebSocket clients.

pub fn connected_client_ids(&self) -> Vec<Uuid>

All currently connected client IDs.

pub fn register_handler<F>(&self, channel: C, handler: F)

where F: Fn(Uuid, Frame<C>, &PushServer<C>) + Send + Sync + 'static,

Register a handler for a specific channel. When a frame arrives on this channel, the handler is invoked with the client ID, the frame, and a reference to the server.

pub async fn upgrade(self: Arc<Self>, ws: WebSocketUpgrade) -> impl IntoResponse

Upgrade an HTTP request to an RPS WebSocket connection.

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

Push a frame to a connected client.

pub fn send_binary( &self, client_id: Uuid, channel: C, bytes: &[u8], mime: &str, name: Option<&str>, pointer_url: Option<&str>, ) -> Result<(), SendError>

Send a binary asset using inline-or-pointer logic.

pub fn send_system(&self, client_id: Uuid, op: SystemOp<C>)

Send a system-level message to a client.

Trait Implementations

impl<C: ChannelKind> Default for PushServer<C>

fn default() -> Self

Returns the “default value” for a type.