Struct TqWebsocket 

pub struct TqWebsocket { /* private fields */ }

天勤 WebSocket 基类

基于 yawc 库实现 WebSocket 连接

Implementations

impl TqWebsocket

pub fn new(url: String, config: WebSocketConfig) -> Self

创建新的 WebSocket 连接

pub async fn init(&self, is_reconnection: bool) -> Result<()>

初始化连接

pub async fn send<T: Serialize>(&self, obj: &T) -> Result<()>

发送消息

pub fn is_ready(&self) -> bool

检查连接是否就绪

pub async fn close(&self) -> Result<()>

关闭连接

pub fn on_message<F>(&self, callback: F)

where F: Fn(Value) + Send + Sync + 'static,

注册消息回调

pub fn on_open<F>(&self, callback: F)

where F: Fn() + Send + Sync + 'static,

注册连接打开回调

pub fn on_close<F>(&self, callback: F)

where F: Fn() + Send + Sync + 'static,

注册连接关闭回调

pub fn on_error<F>(&self, callback: F)

where F: Fn(String) + Send + Sync + 'static,

注册错误回调