Struct CryptoPriceWebSocket 

pub struct CryptoPriceWebSocket { /* private fields */ }

Streams real-time crypto prices from a WebSocket feed.

Supports Binance and Chainlink price sources. Requires explicit subscribe/unsubscribe messages and client-initiated PING every 5 seconds.

Implementations

impl CryptoPriceWebSocket

pub fn new() -> Self

pub fn state(&self) -> WebSocketState

pub fn stream(&self) -> CryptoPriceStream

pub async fn subscribe( &self, source: CryptoPriceSource, symbols: &[String], ) -> Result<(), WebSocketError>

Subscribe to crypto prices for the given source and symbols. Empty symbols subscribes to all available symbols.

pub async fn unsubscribe( &self, source: CryptoPriceSource, symbols: &[String], ) -> Result<(), WebSocketError>

Unsubscribe from crypto prices for the given source and symbols.

pub async fn connect(&mut self) -> Result<(), WebSocketError>

pub async fn disconnect(&mut self) -> Result<(), WebSocketError>

Trait Implementations

impl Default for CryptoPriceWebSocket

fn default() -> Self

Returns the “default value” for a type.