Skip to main content

stream_notifications

Function stream_notifications 

Source
pub async fn stream_notifications(
    base_url: &str,
    token: &str,
) -> Result<impl Stream<Item = Result<NotificationStreamEvent, WsError>>, WsError>
Expand description

Open a WebSocket to /api/v1/notifications/stream and return a stream of parsed events. The token is sent as both an Authorization: Bearer header AND a ?token= query param so the call works against any server config.