[−][src]Trait crypto_ws_client::WSClient
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 messagesurl
- 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.
Implementors
impl<'a> WSClient<'a> for BinanceFutureWSClient<'a>
[src]
pub fn new(on_msg: Box<dyn FnMut(String) + 'a>, url: Option<&str>) -> Self
[src]
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for BinanceInverseSwapWSClient<'a>
[src]
pub fn new(on_msg: Box<dyn FnMut(String) + 'a>, url: Option<&str>) -> Self
[src]
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for BinanceLinearSwapWSClient<'a>
[src]
pub fn new(on_msg: Box<dyn FnMut(String) + 'a>, url: Option<&str>) -> Self
[src]
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for BinanceSpotWSClient<'a>
[src]
pub fn new(on_msg: Box<dyn FnMut(String) + 'a>, url: Option<&str>) -> Self
[src]
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for BitMEXWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BitMEXWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BitMEXWSClient<'a>
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for BitfinexWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BitfinexWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BitfinexWSClient<'a>
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for BitstampWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BitstampWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BitstampWSClient<'a>
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for CoinbaseProWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> CoinbaseProWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> CoinbaseProWSClient<'a>
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for HuobiFutureWSClient<'a>
[src]
pub fn new(on_msg: Box<dyn FnMut(String) + 'a>, url: Option<&str>) -> Self
[src]
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for HuobiInverseSwapWSClient<'a>
[src]
pub fn new(on_msg: Box<dyn FnMut(String) + 'a>, url: Option<&str>) -> Self
[src]
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for HuobiLinearSwapWSClient<'a>
[src]
pub fn new(on_msg: Box<dyn FnMut(String) + 'a>, url: Option<&str>) -> Self
[src]
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for HuobiOptionWSClient<'a>
[src]
pub fn new(on_msg: Box<dyn FnMut(String) + 'a>, url: Option<&str>) -> Self
[src]
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for HuobiSpotWSClient<'a>
[src]
pub fn new(on_msg: Box<dyn FnMut(String) + 'a>, url: Option<&str>) -> Self
[src]
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for KrakenWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> KrakenWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> KrakenWSClient<'a>
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for MXCSpotWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> MXCSpotWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> MXCSpotWSClient<'a>
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for MXCSwapWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> MXCSwapWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> MXCSwapWSClient<'a>
pub fn subscribe_trade(&mut self, channels: &[String])
[src]
pub fn subscribe(&mut self, channels: &[String])
[src]
pub fn unsubscribe(&mut self, channels: &[String])
[src]
pub fn run(&mut self, duration: Option<u64>)
[src]
impl<'a> WSClient<'a> for OKExWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> OKExWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> OKExWSClient<'a>