Struct crypto_ws_client::BitzSpotWSClient

pub struct BitzSpotWSClient { /* private fields */ }

The WebSocket client for Bitz spot market.

• WebSocket API doc: https://apidocv2.bitz.plus/en/#websocket-url
• Trading at https://www.bitz.plus/exchange

Implementations

impl BitzSpotWSClient

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

Creates a websocket client.

Arguments

• tx - The sending part of a channel
• url - Optional server url, usually you don’t need specify it

Trait Implementations

impl WSClient for BitzSpotWSClient

fn subscribe_trade<'life0, 'life1, 'async_trait>(
    &'life0 self,
    symbols: &'life1 [String]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Subscribes to trade channels.

fn subscribe_orderbook<'life0, 'life1, 'async_trait>(
    &'life0 self,
    symbols: &'life1 [String]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Subscribes to incremental level2 orderbook channels.

fn subscribe_orderbook_topk<'life0, 'life1, 'async_trait>(
    &'life0 self,
    symbols: &'life1 [String]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Subscribes to level2 orderbook snapshot channels.

fn subscribe_l3_orderbook<'life0, 'life1, 'async_trait>(
    &'life0 self,
    symbols: &'life1 [String]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Subscribes to level3 orderebook channels.

fn subscribe_ticker<'life0, 'life1, 'async_trait>(
    &'life0 self,
    symbols: &'life1 [String]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Subscribes to ticker channels.

fn subscribe_bbo<'life0, 'life1, 'async_trait>(
    &'life0 self,
    symbols: &'life1 [String]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Subscribes to BBO(best bid & offer) channels.

fn subscribe_candlestick<'life0, 'life1, 'async_trait>(
    &'life0 self,
    symbol_interval_list: &'life1 [(String, usize)]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Subscribes to candlestick channels.

fn subscribe<'life0, 'life1, 'async_trait>(
    &'life0 self,
    topics: &'life1 [(String, String)]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Subscribe to multiple topics.

fn unsubscribe<'life0, 'life1, 'async_trait>(
    &'life0 self,
    topics: &'life1 [(String, String)]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Unsubscribes multiple topics.

fn send<'life0, 'life1, 'async_trait>(
    &'life0 self,
    commands: &'life1 [String]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Send raw JSON commands.

fn run<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    'life0: 'async_trait,
    Self: 'async_trait,

Starts the infinite event loop.

fn close(&self)

Close the connection and break the loop in Run().