Skip to content

PubSubHub

PubSubHub #

send_all #

send_all(message: Any)

send_all_on_topic #

send_all_on_topic(topic: str, message: Any)

send_others #

send_others(except_session_id: str, message: Any)

send_others_on_topic #

send_others_on_topic(
    except_session_id: str, topic: str, message: Any
)

subscribe #

subscribe(session_id: str, handler: Callable)

subscribe_topic #

subscribe_topic(
    session_id: str,
    topic: str,
    handler: Callable | Callable[..., Awaitable[Any]],
)

unsubscribe #

unsubscribe(session_id: str)

unsubscribe_all #

unsubscribe_all(session_id: str)

unsubscribe_topic #

unsubscribe_topic(session_id: str, topic: str)