[−][src]Trait crypto_ws_client::WSClient

pub trait WSClient<'a> {
    pub fn new(on_msg: Box<dyn FnMut(String) + 'a>, url: Option<&str>) -> Self;

    pub fn subscribe_trade(&mut self, pairs: &[String]);

    pub fn subscribe(&mut self, raw_channels: &[String]);

    pub fn unsubscribe(&mut self, raw_channels: &[String]);

    pub fn run(&mut self, duration: Option<u64>);
}

The public interface of every WebSocket client.

Required methods

pub fn new(on_msg: Box<dyn FnMut(String) + 'a>, url: Option<&str>) -> Self[src]

Creates a new client.

Arguments

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

pub fn subscribe_trade(&mut self, pairs: &[String])[src]

Subscribe trade channels.

Each exchange has its own pair formats, for example:

  • BitMEX XBTUSD, XBTM21
  • Binance btcusdt, btcusd_perp
  • OKEx BTC-USDT

pub fn subscribe(&mut self, raw_channels: &[String])[src]

Subscribes channels.

Usually a raw_channel is composed by a channel and a pair, delimited by ,. Sometimes the pair is optional, for example, instrument of BitMEX, market.overview of Huobi.

More examples:

  • BitMEX trade:XBTUSD, quote:XBTM21, instrument
  • Binance btcusdt, btcusd_perp
  • OKEx spot/trade:BTC-USDT

pub fn unsubscribe(&mut self, raw_channels: &[String])[src]

Unsubscribes channels.

pub fn run(&mut self, duration: Option<u64>)[src]

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

Arguments

  • duration - How many seconds to run, None means infinite.
Loading content...

Implementors

impl<'a> WSClient<'a> for BinanceFutureWSClient<'a>[src]

impl<'a> WSClient<'a> for BinanceInverseSwapWSClient<'a>[src]

impl<'a> WSClient<'a> for BinanceLinearSwapWSClient<'a>[src]

impl<'a> WSClient<'a> for BinanceSpotWSClient<'a>[src]

impl<'a> WSClient<'a> for BitMEXWSClient<'a>[src]

impl<'a> WSClient<'a> for BitfinexWSClient<'a>[src]

impl<'a> WSClient<'a> for BitstampWSClient<'a>[src]

impl<'a> WSClient<'a> for CoinbaseProWSClient<'a>[src]

impl<'a> WSClient<'a> for HuobiFutureWSClient<'a>[src]

impl<'a> WSClient<'a> for HuobiInverseSwapWSClient<'a>[src]

impl<'a> WSClient<'a> for HuobiLinearSwapWSClient<'a>[src]

impl<'a> WSClient<'a> for HuobiOptionWSClient<'a>[src]

impl<'a> WSClient<'a> for HuobiSpotWSClient<'a>[src]

impl<'a> WSClient<'a> for KrakenWSClient<'a>[src]

impl<'a> WSClient<'a> for MXCSpotWSClient<'a>[src]

impl<'a> WSClient<'a> for MXCSwapWSClient<'a>[src]

impl<'a> WSClient<'a> for OKExWSClient<'a>[src]

Loading content...