Struct WebSocketInnerClient

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

Fields

credentials: Creds

connector: Connector

handler: Handler

data: Data<T, Transfer>

sender: Sender<Transfer>

Implementations

impl<Transfer, Handler, Connector, Creds, T> WebSocketInnerClient<Transfer, Handler, Connector, Creds, T>

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

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

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