Struct WebSocketClient

pub struct WebSocketClient<Transfer, Handler, Connector, Creds, T, C>
where
    Transfer: MessageTransfer,
    Handler: MessageHandler,
    Connector: Connect,
    Creds: Credentials,
    T: DataHandler,
    C: Callback,
{ /* private fields */ }

Implementations

impl<Transfer, Handler, Connector, Creds, T, C> WebSocketClient<Transfer, Handler, Connector, Creds, T, C>

where Transfer: MessageTransfer + 'static, Handler: MessageHandler<Transfer = Transfer> + 'static, Creds: Credentials + 'static, Connector: Connect<Creds = Creds> + 'static, T: DataHandler<Transfer = Transfer> + 'static, C: Callback<T = T, Transfer = Transfer> + 'static,

pub async fn init( credentials: Creds, connector: Connector, data: Data<T, Transfer>, handler: Handler, timeout: Duration, reconnect_callback: Option<C>, ) -> BinaryOptionsResult<Self>

impl WebSocketClient<WebSocketMessage, Handler, PocketConnect, Ssid, PocketData, PocketCallback>

pub async fn new(ssid: impl ToString) -> BinaryOptionsResult<Self>

pub async fn trade( &self, asset: impl ToString, action: Action, amount: f64, time: u32, ) -> BinaryOptionsResult<(Uuid, Deal)>

pub async fn buy( &self, asset: impl ToString, amount: f64, time: u32, ) -> BinaryOptionsResult<(Uuid, Deal)>

pub async fn sell( &self, asset: impl ToString, amount: f64, time: u32, ) -> BinaryOptionsResult<(Uuid, Deal)>

pub async fn get_deal_end_time(&self, id: Uuid) -> Option<DateTime<Utc>>

pub async fn check_results(&self, trade_id: Uuid) -> BinaryOptionsResult<Deal>

pub async fn get_candles( &self, asset: impl ToString, period: i64, offset: i64, ) -> BinaryOptionsResult<Vec<DataCandle>>

pub async fn history( &self, asset: impl ToString, period: i64, ) -> BinaryOptionsResult<Vec<DataCandle>>

pub async fn get_closed_deals(&self) -> Vec<Deal>

pub async fn clear_closed_deals(&self)

pub async fn get_opened_deals(&self) -> Vec<Deal>

pub async fn get_balance(&self) -> UpdateBalance

pub async fn get_payout(&self) -> HashMap<String, i32>

pub async fn subscribe_symbol( &self, asset: impl ToString, ) -> BinaryOptionsResult<StreamAsset>

pub async fn subscribe_symbol_chuncked( &self, asset: impl ToString, chunck_size: impl Into<usize>, ) -> BinaryOptionsResult<StreamAsset>

pub fn kill(self)

Methods from Deref<Target = WebSocketInnerClient<Transfer, Handler, Connector, Creds, T, C>>

pub async fn send_message( &self, msg: Transfer, response_type: Transfer::Info, validator: impl Fn(&Transfer) -> bool + Send + Sync, ) -> BinaryOptionsResult<Transfer>

pub async fn send_message_with_timout( &self, timeout: Duration, task: impl ToString, msg: Transfer, response_type: Transfer::Info, validator: impl Fn(&Transfer) -> bool + Send + Sync, ) -> BinaryOptionsResult<Transfer>

pub async fn send_message_with_timeout_and_retry( &self, timeout: Duration, task: impl ToString, msg: Transfer, response_type: Transfer::Info, validator: impl Fn(&Transfer) -> bool + Send + Sync, ) -> BinaryOptionsResult<Transfer>

Trait Implementations

impl<Transfer, Handler, Connector, Creds, T, C> Clone for WebSocketClient<Transfer, Handler, Connector, Creds, T, C>

where Transfer: MessageTransfer + Clone, Handler: MessageHandler + Clone, Connector: Connect + Clone, Creds: Credentials + Clone, T: DataHandler + Clone, C: Callback + Clone,

fn clone(&self) -> WebSocketClient<Transfer, Handler, Connector, Creds, T, C>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Transfer, Handler, Connector, Creds, T, C> Deref for WebSocketClient<Transfer, Handler, Connector, Creds, T, C>

where Transfer: MessageTransfer, Handler: MessageHandler, Connector: Connect, Creds: Credentials, T: DataHandler, C: Callback,

type Target = WebSocketInnerClient<Transfer, Handler, Connector, Creds, T, C>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.