Struct MarketStream 

pub struct MarketStream { /* private fields */ }

Market data stream client for receiving real-time market updates.

This client manages WebSocket connections to the DeltaDeFi market streaming API and provides parsed messages through async channels.

Available Streams

• Depth Stream: Order book depth updates
• Price Stream: Market price changes
• Recent Trades Stream: Recent trade executions
• OHLC/Graph Stream: Candlestick chart data

Example

use deltadefi::{DeltaDeFi, Stage};

let client = DeltaDeFi::new("api-key".to_string(), Stage::Staging, None)?;

// Subscribe to market depth for ADAUSDM
let (mut handle, mut receiver) = client.market_stream
    .subscribe_depth("ADAUSDM", None).await?;

while let Some(message) = receiver.recv().await {
    if let MarketStreamMessage::Depth(depth) = message {
        println!("Bids: {:?}, Asks: {:?}", depth.bids.len(), depth.asks.len());
    }
}

handle.close().await;

Implementations

impl MarketStream

pub fn new(ws_url: String) -> Self

Create a new MarketStream instance.

pub async fn subscribe_depth( &self, symbol: &str, buffer_size: Option<usize>, ) -> Result<(MarketStreamHandle, Receiver<MarketStreamMessage>), WError>

Subscribe to the market depth stream for a symbol.

Receives order book depth updates showing bids and asks. This is the simple API without automatic reconnection.

Arguments

• symbol - Trading pair symbol (e.g., “ADAUSDM”)
• buffer_size - Size of the message buffer (default: 100)

Returns

A tuple containing the stream handle and message receiver.

pub async fn subscribe_price( &self, symbol: &str, buffer_size: Option<usize>, ) -> Result<(MarketStreamHandle, Receiver<MarketStreamMessage>), WError>

Subscribe to the market price stream for a symbol.

Receives price updates when trades occur. This is the simple API without automatic reconnection.

Arguments

• symbol - Trading pair symbol (e.g., “ADAUSDM”)
• buffer_size - Size of the message buffer (default: 100)

Returns

A tuple containing the stream handle and message receiver.

pub async fn subscribe_recent_trades( &self, symbol: &str, buffer_size: Option<usize>, ) -> Result<(MarketStreamHandle, Receiver<MarketStreamMessage>), WError>

Subscribe to the recent trades stream for a symbol.

Receives notifications about recent trade executions. This is the simple API without automatic reconnection.

Arguments

• symbol - Trading pair symbol (e.g., “ADAUSDM”)
• buffer_size - Size of the message buffer (default: 100)

Returns

A tuple containing the stream handle and message receiver.

pub async fn subscribe_ohlc( &self, symbol: &str, interval: &str, buffer_size: Option<usize>, ) -> Result<(MarketStreamHandle, Receiver<MarketStreamMessage>), WError>

Subscribe to the OHLC/graph stream for a symbol.

Receives candlestick chart data updates. This is the simple API without automatic reconnection.

Arguments

• symbol - Trading pair symbol (e.g., “ADAUSDM”)
• interval - Time interval (e.g., “5m”, “15m”, “30m”, “1h”, “1d”)
• buffer_size - Size of the message buffer (default: 100)

Returns

A tuple containing the stream handle and message receiver.

pub async fn subscribe_depth_with_reconnect( &self, symbol: &str, buffer_size: Option<usize>, reconnect_config: Option<ReconnectConfig>, ) -> Result<(MarketStreamHandle, Receiver<MarketStreamEvent>), WError>

Subscribe to depth stream with automatic reconnection.

Arguments

• symbol - Trading pair symbol (e.g., “ADAUSDM”)
• buffer_size - Size of the message buffer (default: 100)
• reconnect_config - Configuration for reconnection behavior

pub async fn subscribe_price_with_reconnect( &self, symbol: &str, buffer_size: Option<usize>, reconnect_config: Option<ReconnectConfig>, ) -> Result<(MarketStreamHandle, Receiver<MarketStreamEvent>), WError>

Subscribe to price stream with automatic reconnection.

Arguments

• symbol - Trading pair symbol (e.g., “ADAUSDM”)
• buffer_size - Size of the message buffer (default: 100)
• reconnect_config - Configuration for reconnection behavior

pub async fn subscribe_recent_trades_with_reconnect( &self, symbol: &str, buffer_size: Option<usize>, reconnect_config: Option<ReconnectConfig>, ) -> Result<(MarketStreamHandle, Receiver<MarketStreamEvent>), WError>

Subscribe to recent trades stream with automatic reconnection.

Arguments

• symbol - Trading pair symbol (e.g., “ADAUSDM”)
• buffer_size - Size of the message buffer (default: 100)
• reconnect_config - Configuration for reconnection behavior

pub async fn subscribe_ohlc_with_reconnect( &self, symbol: &str, interval: &str, buffer_size: Option<usize>, reconnect_config: Option<ReconnectConfig>, ) -> Result<(MarketStreamHandle, Receiver<MarketStreamEvent>), WError>

Subscribe to OHLC stream with automatic reconnection.

Arguments

• symbol - Trading pair symbol (e.g., “ADAUSDM”)
• interval - Time interval (e.g., “5m”, “15m”, “30m”, “1h”, “1d”)
• buffer_size - Size of the message buffer (default: 100)
• reconnect_config - Configuration for reconnection behavior

pub async fn subscribe_depth_with_callback<F, Fut>( &self, symbol: &str, callback: F, ) -> Result<(), WError>

where F: FnMut(MarketStreamMessage) -> Fut, Fut: Future<Output = bool>,

Subscribe to depth stream with a callback function.

Arguments

• symbol - Trading pair symbol
• callback - Async function called for each message. Return false to stop.

pub async fn subscribe_price_with_callback<F, Fut>( &self, symbol: &str, callback: F, ) -> Result<(), WError>

where F: FnMut(MarketStreamMessage) -> Fut, Fut: Future<Output = bool>,

Subscribe to price stream with a callback function.

Arguments

• symbol - Trading pair symbol
• callback - Async function called for each message. Return false to stop.

pub async fn subscribe_recent_trades_with_callback<F, Fut>( &self, symbol: &str, callback: F, ) -> Result<(), WError>

where F: FnMut(MarketStreamMessage) -> Fut, Fut: Future<Output = bool>,

Subscribe to recent trades stream with a callback function.

Arguments

• symbol - Trading pair symbol
• callback - Async function called for each message. Return false to stop.

pub async fn subscribe_ohlc_with_callback<F, Fut>( &self, symbol: &str, interval: &str, callback: F, ) -> Result<(), WError>

where F: FnMut(MarketStreamMessage) -> Fut, Fut: Future<Output = bool>,

Subscribe to OHLC stream with a callback function.

Arguments

• symbol - Trading pair symbol
• interval - Time interval (e.g., “5m”, “1h”)
• callback - Async function called for each message. Return false to stop.