Struct Request 

pub struct Request { /* private fields */ }

Okx websocket api request.

Implementations

impl Request

pub fn subscribe_tickers(inst: &str) -> Request

Subscribe tickers.

pub fn subscribe_orders(inst: &str) -> Request

Subscribe orders.

pub fn subscribe_trades(inst: &str) -> Request

Subscribe trades.

pub fn subscribe_bid_ask(inst: &str) -> Request

Subscribe bid/ask.

pub fn subscribe(args: Args) -> Request

Subscribe to the given channel.

pub fn order(req: &PlaceOrder) -> Request

Order request.

pub fn cancel_order(inst: &str, id: &str) -> Request

Cancel order request.

pub fn reconnect() -> Request

Reconnect.

Trait Implementations

impl Adaptor<CancelOrder> for Request

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

where Request: Sized,

Convert from request.

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

Convert into response.

impl Adaptor<PlaceOrder> for Request

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

where Request: Sized,

Convert from request.

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

Convert into response.

impl Adaptor<SubscribeBidAsk> for Request

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

Convert from request.

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

Convert into response.

impl Adaptor<SubscribeInstruments> for Request

fn from_request(req: SubscribeInstruments) -> Result<Request, ExchangeError>

where Request: Sized,

Convert from request.

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

Convert into response.

impl Adaptor<SubscribeOrders> for Request

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

where Request: Sized,

Convert from request.

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

Convert into response.

impl Adaptor<SubscribeTrades> for Request

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

Convert from request.

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

Convert into response.

impl Request for Request

type Response = Response

Response type.

impl Service<Request> for Channel

type Response = Response

Responses given by the service.

type Error = ExchangeError

Errors produced by the service.

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

The future response value.

fn poll_ready( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<(), <Channel as Service<Request>>::Error>>

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

fn call(&mut self, req: Request) -> <Channel as Service<Request>>::Future

Process the request and return the response asynchronously.

impl Service<Request> for Protocol

type Response = Response

Responses given by the service.

type Error = ProtocolError

Errors produced by the service.

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

The future response value.

fn poll_ready( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<(), <Protocol as Service<Request>>::Error>>

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

fn call(&mut self, req: Request) -> <Protocol as Service<Request>>::Future

Process the request and return the response asynchronously.

impl TryFrom<SubscribeTickers> for Request

type Error = ExchangeError

The type returned in the event of a conversion error.

fn try_from( value: SubscribeTickers, ) -> Result<Request, <Request as TryFrom<SubscribeTickers>>::Error>

Performs the conversion.