Struct WsRequest 

pub struct WsRequest { /* private fields */ }

Binance websocket request.

Implementations

impl WsRequest

pub fn subscribe_stream(name: Name) -> Self

Subscribe to a stream. No matter whether the stream is main or sub.

pub fn subscribe(stream: Name) -> Self

👎Deprecated: Use subscribe_stream instead

Subscribe to a sub stream.

pub fn sub_stream(stream: Name) -> Self

Subscribe to a sub stream.

pub fn timeout(self, duration: Duration) -> Self

Set stream timeout. Default to the default_stream_timeout in protocol config.

pub fn main_stream(stream: Name) -> Self

Subscribe to a main stream topic.

pub fn reconnect() -> Self

Reconnect.

pub fn dispatch_trades(trades: SubscribeTrades) -> Self

Dispatch trades.

pub fn dispatch_bid_ask(bid_ask: SubscribeBidAsk) -> Self

Dispatch bid ask.

Trait Implementations

impl From<WsRequest> for Request

fn from(req: WsRequest) -> Self

Converts to this type from the input type.

impl Service<WsRequest> for BinanceWebsocketApi

type Response = WsResponse

Responses given by the service.

type Error = WsError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<BinanceWebsocketApi as Service<WsRequest>>::Response, <BinanceWebsocketApi as Service<WsRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: WsRequest) -> Self::Future

Process the request and return the response asynchronously.

impl Service<WsRequest> for WsClient

type Response = WsResponse

Responses given by the service.

type Error = WsError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<WsClient as Service<WsRequest>>::Response, <WsClient as Service<WsRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: WsRequest) -> Self::Future

Process the request and return the response asynchronously.