Struct WsClient

pub struct WsClient { /* private fields */ }

Longbridge Websocket client

Implementations

impl WsClient

pub async fn open( request: impl IntoClientRequest, version: ProtocolVersion, codec: CodecType, platform: Platform, event_sender: UnboundedSender<WsEvent>, rate_limit: Option<RateLimit>, ) -> WsClientResult<Self>

Connect to url and returns a WsClient object

pub async fn request_auth( &self, otp: impl Into<String>, ) -> WsClientResult<WsSession>

Send an authentication request to get a WsSession

Reference: https://open.longbridgeapp.com/en/docs/socket-token-api Reference: https://open.longbridgeapp.com/en/docs/socket/control-command#auth

pub async fn request_reconnect( &self, session_id: impl Into<String>, ) -> WsClientResult<WsSession>

Send a reconnect request to get a WsSession

Reference: https://open.longbridgeapp.com/en/docs/socket/control-command#reconnect

pub async fn request_raw( &self, command_code: u8, timeout: Option<Duration>, body: Vec<u8>, ) -> WsClientResult<Vec<u8>>

Send a raw request

pub async fn request<T, R>( &self, command_code: u8, timeout: Option<Duration>, req: T, ) -> WsClientResult<R>

where T: Message, R: Message + Default,

Send a request T to get a response R

Trait Implementations

impl Clone for WsClient

fn clone(&self) -> WsClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.