Struct WebSocketStreamsApiClient 

pub struct WebSocketStreamsApiClient { /* private fields */ }

Implementations

impl WebSocketStreamsApiClient

pub fn new(websocket_streams_base: Arc<WebsocketStreams>) -> Self

Trait Implementations

impl WebSocketStreamsApi for WebSocketStreamsApiClient

fn agg_trade<'life0, 'async_trait>( &'life0 self, params: AggTradeParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<AggTradeResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn all_market_rolling_window_ticker<'life0, 'async_trait>( &'life0 self, params: AllMarketRollingWindowTickerParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<Vec<AllMarketRollingWindowTickerResponseInner>>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn all_mini_ticker<'life0, 'async_trait>( &'life0 self, params: AllMiniTickerParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<Vec<AllMiniTickerResponseInner>>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn avg_price<'life0, 'async_trait>( &'life0 self, params: AvgPriceParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<AvgPriceResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn block_trade<'life0, 'async_trait>( &'life0 self, params: BlockTradeParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<BlockTradeResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn book_ticker<'life0, 'async_trait>( &'life0 self, params: BookTickerParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<BookTickerResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn diff_book_depth<'life0, 'async_trait>( &'life0 self, params: DiffBookDepthParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<DiffBookDepthResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn kline<'life0, 'async_trait>( &'life0 self, params: KlineParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<KlineResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn kline_offset<'life0, 'async_trait>( &'life0 self, params: KlineOffsetParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<KlineOffsetResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn mini_ticker<'life0, 'async_trait>( &'life0 self, params: MiniTickerParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<MiniTickerResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn partial_book_depth<'life0, 'async_trait>( &'life0 self, params: PartialBookDepthParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<PartialBookDepthResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn reference_price<'life0, 'async_trait>( &'life0 self, params: ReferencePriceParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<ReferencePriceResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn rolling_window_ticker<'life0, 'async_trait>( &'life0 self, params: RollingWindowTickerParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<RollingWindowTickerResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn ticker<'life0, 'async_trait>( &'life0 self, params: TickerParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<TickerResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn trade<'life0, 'async_trait>( &'life0 self, params: TradeParams, ) -> Pin<Box<dyn Future<Output = Result<Arc<WebsocketStream<TradeResponse>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,