Struct crypto_ws_client::HuobiSpotWSClient

pub struct HuobiSpotWSClient { /* fields omitted */ }

Huobi Spot market.

• WebSocket API doc: https://huobiapi.github.io/docs/spot/v1/en/
• Trading at: https://www.huobi.com/en-us/exchange/

Implementations

impl HuobiSpotWSClient

pub fn new(tx: Sender<String>, url: Option<&str>) -> Self

Creates a Huobi websocket client.

Arguments

• on_msg - A callback function to process websocket messages
• url - Optional server url, usually you don’t need specify it

Trait Implementations

impl WSClient for HuobiSpotWSClient

fn subscribe_trade(&self, channels: &[String])

Subscribes to trade channels.

fn subscribe_orderbook(&self, channels: &[String])

Subscribes to incremental level2 orderbook channels.

fn subscribe_orderbook_topk(&self, channels: &[String])

Subscribes to level2 orderbook snapshot channels.

fn subscribe_l3_orderbook(&self, channels: &[String])

Subscribes to level3 orderebook channels.

fn subscribe_ticker(&self, channels: &[String])

Subscribes to ticker channels.

fn subscribe_bbo(&self, channels: &[String])

Subscribes to BBO(best bid & offer) channels.

fn subscribe_candlestick(&self, symbol_interval_list: &[(String, usize)])

Subscribes to candlestick channels.

fn subscribe(&self, channels: &[String])

Subscribes to raw channels, lower level API.

fn unsubscribe(&self, channels: &[String])

Unsubscribes from raw channels, lower level API.

fn run(&self, duration: Option<u64>)

Starts the infinite loop until time is up or the server closes the connection.

fn close(&self)

Breaks the loop and closes the connection.