Enum BinanceFuturesWsStreamsMessage 

pub enum BinanceFuturesWsStreamsMessage {
    AggTrade(BinanceFuturesAggTradeMsg),
    Trade(BinanceFuturesTradeMsg),
    BookTicker(BinanceFuturesBookTickerMsg),
    DepthUpdate(BinanceFuturesDepthUpdateMsg),
    MarkPrice(BinanceFuturesMarkPriceMsg),
    Kline(BinanceFuturesKlineMsg),
    ForceOrder(BinanceFuturesLiquidationMsg),
    Ticker(BinanceFuturesTickerMsg),
    AccountUpdate(BinanceFuturesAccountUpdateMsg),
    OrderUpdate(Box<BinanceFuturesOrderUpdateMsg>),
    TradeLite(Box<BinanceFuturesTradeLiteMsg>),
    AlgoUpdate(Box<BinanceFuturesAlgoUpdateMsg>),
    MarginCall(BinanceFuturesMarginCallMsg),
    AccountConfigUpdate(BinanceFuturesAccountConfigMsg),
    ListenKeyExpired,
    Error(BinanceFuturesWsErrorMsg),
    Reconnected(Vec<u64>),
    Unsubscribed {
        streams: Vec<String>,
        correlation: Option<u64>,
    },
}

Output message from the Futures WebSocket streams handler.

Contains venue-specific types for both market data and user data stream events. The data and execution client layers convert these to Nautilus domain types using parse functions with instrument context.

Variants

AggTrade(BinanceFuturesAggTradeMsg)

Aggregate trade stream.

Trade(BinanceFuturesTradeMsg)

Trade stream.

BookTicker(BinanceFuturesBookTickerMsg)

Best bid/ask (book ticker) stream.

DepthUpdate(BinanceFuturesDepthUpdateMsg)

Order book depth update stream.

MarkPrice(BinanceFuturesMarkPriceMsg)

Mark price stream.

Kline(BinanceFuturesKlineMsg)

Kline/candlestick stream.

ForceOrder(BinanceFuturesLiquidationMsg)

Force liquidation order stream.

Ticker(BinanceFuturesTickerMsg)

24hr ticker stream.

AccountUpdate(BinanceFuturesAccountUpdateMsg)

Account update (balance/position changes).

OrderUpdate(Box<BinanceFuturesOrderUpdateMsg>)

Order/trade update.

TradeLite(Box<BinanceFuturesTradeLiteMsg>)

Trade Lite fill notification (low-latency subset of OrderUpdate).

AlgoUpdate(Box<BinanceFuturesAlgoUpdateMsg>)

Algo order update (conditional orders via Algo Service).

MarginCall(BinanceFuturesMarginCallMsg)

Margin call warning.

AccountConfigUpdate(BinanceFuturesAccountConfigMsg)

Account configuration change (leverage, etc.).

ListenKeyExpired

Listen key expired.

Error(BinanceFuturesWsErrorMsg)

Error from the server.

Reconnected(Vec<u64>)

WebSocket reconnected; carries the correlation IDs of the unsubscribe requests the old connection abandoned.

Unsubscribed

Venue confirmation of an unsubscribe request, carrying the confirmed stream names and the request’s correlation ID when one was supplied.

Fields

streams: Vec<String>

Confirmed stream names.

correlation: Option<u64>

Correlates the confirmation with the caller’s unsubscribe lifecycle.

Trait Implementations

impl Clone for BinanceFuturesWsStreamsMessage

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BinanceFuturesWsStreamsMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.