Struct WebSocketInnerClient

pub struct WebSocketInnerClient<Transfer, Handler, Connector, Creds, T, C>
where
    Transfer: MessageTransfer,
    Handler: MessageHandler,
    Connector: Connect,
    Creds: Credentials,
    T: DataHandler,
    C: Callback,
{
    pub credentials: Creds,
    pub connector: Connector,
    pub handler: Handler,
    pub data: Data<T, Transfer>,
    pub sender: SenderMessage<Transfer>,
    pub reconnect_callback: Option<C>,
    /* private fields */
}

Fields

credentials: Creds

connector: Connector

handler: Handler

data: Data<T, Transfer>

sender: SenderMessage<Transfer>

reconnect_callback: Option<C>

Implementations

impl<Transfer, Handler, Connector, Creds, T, C> WebSocketInnerClient<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>

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>