Skip to main content

spawn_stream_subscriber

Function spawn_stream_subscriber 

Source
pub fn spawn_stream_subscriber(wake_tx: Sender<()>)
Expand description

Spawn the stream-subscriber thread. Returns immediately; the thread runs until process exit. wake_tx is signaled on every received SSE data: line (any event, no parsing of body). Errors during connect or stream-read trigger reconnect-with-backoff, never panic.