[−][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(&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.

Required methods

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

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])[src]

Subscribe channels.

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

Unsubscribe channels.

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

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)[src]

Close the client.

Loading content...

Implementors

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

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

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

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

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

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

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

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

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

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

Loading content...