Struct WsStream 

pub struct WsStream { /* private fields */ }

A WebSocket stream that connects to Binance and receives real-time kline updates.

Implementations

impl WsStream

pub fn new(symbol: impl Into<String>, interval: impl Into<String>) -> Self

Create a new WebSocket stream for the given symbol and interval.

pub fn start(&self) -> Receiver<Candle>

Start streaming and return a receiver for candle updates.

Spawns a background thread that maintains the WebSocket connection. Returns a receiver that yields Candle values as they arrive.