Enum IncomingMessage 

pub enum IncomingMessage {
    Command(CommandMsg),
    TradeReply(Box<TradeReply>),
    Ticker(Box<TickerMsg>),
    Trade(TradeMsg),
    KLine(KLineMsg),
    Orderbook(OrderbookMsg),
    AllLiquidation(AllLiquidationMsg),
    Topic(TopicMessage),
}

A message from a Bybit stream; parse it with IncomingMessage::from_json.

Variants

Command(CommandMsg)

Reply to a command (subscribe, auth, heartbeat, …).

TradeReply(Box<TradeReply>)

Reply of the order entry stream (/v5/trade): auth, order.*.

Ticker(Box<TickerMsg>)

Ticker (tickers.*).

Trade(TradeMsg)

Public trades (publicTrade.*).

KLine(KLineMsg)

Klines (kline.*).

Orderbook(OrderbookMsg)

Order book (orderbook.*).

AllLiquidation(AllLiquidationMsg)

Liquidations (allLiquidation.*).

Topic(TopicMessage)

Private stream data (orders, positions, executions, wallet, …).

Implementations

impl IncomingMessage

pub fn from_json(json: &str) -> Result<Self, Error<Error>>

Parse a WebSocket text frame.

Prefer this over the derived Deserialize impl (which is #[serde(untagged)] and tries every variant in turn): the op/topic fields are read first and only the matching type is deserialized, so errors point at the offending field (e.g. data.b[0]) and topics with a category suffix such as order.linear are recognized.

pub fn is_pong(&self) -> bool

A heartbeat reply in the pong form (private and option/spread public streams).

pub fn is_ping(&self) -> bool

A heartbeat reply in the ping form (spot and linear/inverse public streams).

Trait Implementations

impl Debug for IncomingMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for IncomingMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for IncomingMessage

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for IncomingMessage