[−][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]
Create a new client.
Arguments
on_msg
- The message handlerurl
- 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.
Implementors
impl<'a> WSClient<'a> for BinanceDeliveryWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BinanceDeliveryWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BinanceDeliveryWSClient<'a>
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 BinanceFuturesWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BinanceFuturesWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BinanceFuturesWSClient<'a>
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>
) -> BinanceSpotWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BinanceSpotWSClient<'a>
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(&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(&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 BitstampSpotWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BitstampSpotWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> BitstampSpotWSClient<'a>
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(&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 HuobiCoinSwapWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> HuobiCoinSwapWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> HuobiCoinSwapWSClient<'a>
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 HuobiFuturesWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> HuobiFuturesWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> HuobiFuturesWSClient<'a>
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>
) -> HuobiOptionWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> HuobiOptionWSClient<'a>
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>
) -> HuobiSpotWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> HuobiSpotWSClient<'a>
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 HuobiUsdtSwapWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> HuobiUsdtSwapWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> HuobiUsdtSwapWSClient<'a>
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 KrakenSpotWSClient<'a>
[src]
pub fn new(
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> KrakenSpotWSClient<'a>
[src]
on_msg: Box<dyn FnMut(String) + 'a>,
url: Option<&str>
) -> KrakenSpotWSClient<'a>
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(&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>