Struct Hub 

pub struct Hub { /* private fields */ }

Available on non-WebAssembly only.

Topics and their subscribers; cheap to clone (all clones share them).

Implementations

impl Hub

pub fn new() -> Hub

pub fn publish(&self, topic: &str, message: &str) -> usize

Send message to every subscriber of topic; the number it was delivered to. SSE clients get it as an event named after the topic (EventSource.addEventListener(topic, …)), WebSocket clients as a text message.

pub fn sse(&self, topic: &str) -> Response

A streaming SSE response subscribed to topic: return it from the handler.

pub fn subscribe_websocket(&self, topic: &str, sender: WebSocketSender)

Subscribe a WebSocket client (its sender) to topic.

pub fn serve_websocket<F>( &self, ws: WebSocketConnection, topic: &str, on_message: F, )

where F: Fn(&Hub, &str, &str),

Subscribe ws to topic and read its messages until it closes, handing each text message to on_message(hub, topic, text). Run it in a .websocket(…) handler.

pub fn subscribe(&self, topic: &str) -> Receiver<String>

Subscribe in-process: every message to topic arrives on the receiver until it’s dropped.

pub fn subscribers(&self, topic: &str) -> usize

How many subscribers topic has (some may have gone away since the last publish).

pub fn topics(&self) -> Vec<String>

The topics that have subscribers, sorted.

Trait Implementations

impl Clone for Hub

fn clone(&self) -> Hub

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Hub

fn default() -> Hub

Returns the “default value” for a type.