Struct WebSocketClient 

pub struct WebSocketClient { /* private fields */ }

Streams enriched articles in real time. Duplicate articles (same link within the last 10 deliveries) are suppressed.

Implementations

impl WebSocketClient

pub fn new(cfg: Config, opts: WebSocketOptions) -> Self

Returns a streaming client with custom options. Client instances created by Client::new use default options.

pub fn stream( &self, params: GetArticlesWebSocketParams, ) -> ArticleStream<Article>

Connects to the finlight WebSocket and yields articles matching params. Reconnects (exponential backoff, proactive rotation, rate-limit waits) are handled internally. Err items are terminal (e.g. Error::Blocked); the stream ends after yielding one. End the stream by dropping it.

Must be called within a tokio runtime.