Enum Request 

pub enum Request {
    Http(RestRequest<Payload>),
    Ws(WsRequest),
}

Binance request.

Variants

Http(RestRequest<Payload>)

Http request.

Ws(WsRequest)

Websocket request.

Implementations

impl Request

pub fn with_rest_payload<T>(payload: T) -> Self

where T: Rest,

Create a request from rest payload.

pub fn subscribe(stream: Name) -> Self

Create a request to subscribe to a ws stream.

pub fn subcribe_main(stream: Name) -> Self

Main stream subcribe.

Trait Implementations

impl Adaptor<CancelOrder> for Request

fn from_request(req: CancelOrder) -> Result<Self, ExchangeError>

Convert from request.

fn into_response( resp: Self::Response, ) -> Result<<CancelOrder as Request>::Response, ExchangeError>

Convert into response.

impl Adaptor<FetchInstruments> for Request

fn from_request(_req: FetchInstruments) -> Result<Self, ExchangeError>

where Self: Sized,

Convert from request.

fn into_response( resp: Self::Response, ) -> Result<<FetchInstruments as Request>::Response, ExchangeError>

Convert into response.

impl Adaptor<GetOrder> for Request

fn from_request(req: GetOrder) -> Result<Self, ExchangeError>

Convert from request.

fn into_response( resp: Self::Response, ) -> Result<<GetOrder as Request>::Response, ExchangeError>

Convert into response.

impl Adaptor<PlaceOrder> for Request

fn from_request(req: PlaceOrder) -> Result<Self, ExchangeError>

Convert from request.

fn into_response( resp: Self::Response, ) -> Result<<PlaceOrder as Request>::Response, ExchangeError>

Convert into response.

impl Adaptor<QueryFirstCandles> for Request

fn from_request(req: QueryFirstCandles) -> Result<Self, ExchangeError>

Convert from request.

fn into_response(resp: Self::Response) -> Result<CandleStream, ExchangeError>

Convert into response.

impl Adaptor<Reconnect> for Request

fn from_request(_req: Reconnect) -> Result<Self, ExchangeError>

Convert from request.

fn into_response( _resp: Self::Response, ) -> Result<<Reconnect as Request>::Response, ExchangeError>

Convert into response.

impl Adaptor<SubscribeBidAsk> for Request

fn from_request(req: SubscribeBidAsk) -> Result<Self, ExchangeError>

Convert from request.

fn into_response(resp: Self::Response) -> Result<BidAskStream, ExchangeError>

Convert into response.

impl Adaptor<SubscribeOrders> for Request

fn from_request(req: SubscribeOrders) -> Result<Self, ExchangeError>

Convert from request.

fn into_response(resp: Self::Response) -> Result<OrderStream, ExchangeError>

Convert into response.

impl Adaptor<SubscribeTrades> for Request

fn from_request(req: SubscribeTrades) -> Result<Self, ExchangeError>

Convert from request.

fn into_response(resp: Self::Response) -> Result<TradeStream, ExchangeError>

Convert into response.

impl From<WsRequest> for Request

fn from(req: WsRequest) -> Self

Converts to this type from the input type.

impl Request for Request

type Response = Response

Response type.

impl Service<Request> for Binance

type Response = Response

Responses given by the service.

type Error = ExchangeError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<Binance as Service<Request>>::Response, <Binance as Service<Request>>::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: Request) -> Self::Future

Process the request and return the response asynchronously.

impl Service<Request> for BinanceRestApi<HttpsChannel>

type Response = Response

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<BinanceRestApi<HttpsChannel> as Service<Request>>::Response, <BinanceRestApi<HttpsChannel> as Service<Request>>::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: Request) -> Self::Future

Process the request and return the response asynchronously.

impl Service<Request> for BinanceWebsocketApi

type Response = Response

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<BinanceWebsocketApi as Service<Request>>::Response, <BinanceWebsocketApi as Service<Request>>::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: Request) -> Self::Future

Process the request and return the response asynchronously.