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>, reconnect_time: Option<u64>, ) -> BinaryOptionsResult<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.