Trait crypto_ws_client::WSClient

pub trait WSClient {
    type Exchange;
    pub fn init(on_msg: fn(_: String), url: Option<&str>) -> Self::Exchange;
    pub fn subscribe(&mut self, channels: &[String]);
    pub fn unsubscribe(&mut self, channels: &[String]);
    pub fn run(&mut self, duration: Option<u64>);
    pub fn close(&mut self);
}

The public interface of every WebSocket client.

Associated Types

type Exchange

Exchange specific WebSocket client.

Loading content...

Required methods

pub fn init(on_msg: fn(_: String), url: Option<&str>) -> Self::Exchange

Create a new client.

Arguments

• on_msg - The message handler
• url - Optional server url, usually you don't need specify it

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

Subscribe channels.

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

Unsubscribe channels.

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

Start the infinite loop until the server closes the connection.

Arguments

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

pub fn close(&mut self)

Close the client.

Loading content...

Implementors

impl WSClient for BinanceDeliveryWSClient

type Exchange = BinanceDeliveryWSClient

pub fn init(on_msg: fn(_: String), url: Option<&str>) -> BinanceDeliveryWSClient

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

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

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

pub fn close(&mut self)

impl WSClient for BinanceFuturesWSClient

type Exchange = BinanceFuturesWSClient

pub fn init(on_msg: fn(_: String), url: Option<&str>) -> BinanceFuturesWSClient

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

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

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

pub fn close(&mut self)

impl WSClient for BinanceSpotWSClient

type Exchange = BinanceSpotWSClient

pub fn init(on_msg: fn(_: String), url: Option<&str>) -> BinanceSpotWSClient

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

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

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

pub fn close(&mut self)

impl WSClient for HuobiCoinSwapWSClient

type Exchange = HuobiCoinSwapWSClient

pub fn init(on_msg: fn(_: String), url: Option<&str>) -> HuobiCoinSwapWSClient

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

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

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

pub fn close(&mut self)

impl WSClient for HuobiFuturesWSClient

type Exchange = HuobiFuturesWSClient

pub fn init(on_msg: fn(_: String), url: Option<&str>) -> HuobiFuturesWSClient

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

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

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

pub fn close(&mut self)

impl WSClient for HuobiOptionWSClient

type Exchange = HuobiOptionWSClient

pub fn init(on_msg: fn(_: String), url: Option<&str>) -> HuobiOptionWSClient

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

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

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

pub fn close(&mut self)

impl WSClient for HuobiSpotWSClient

type Exchange = HuobiSpotWSClient

pub fn init(on_msg: fn(_: String), url: Option<&str>) -> HuobiSpotWSClient

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

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

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

pub fn close(&mut self)

impl WSClient for HuobiUsdtSwapWSClient

type Exchange = HuobiUsdtSwapWSClient

pub fn init(on_msg: fn(_: String), url: Option<&str>) -> HuobiUsdtSwapWSClient

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

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

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

pub fn close(&mut self)

impl WSClient for OKExWSClient

type Exchange = OKExWSClient

pub fn init(on_msg: fn(_: String), url: Option<&str>) -> OKExWSClient

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

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

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

pub fn close(&mut self)

Loading content...