Struct Chat 

pub struct Chat { /* private fields */ }

私聊客户端

Implementations

impl Chat

pub fn new(api_key: String) -> Self

pub async fn connect( &mut self, reload: bool, user: Option<String>, ) -> Result<(), WebSocketError>

pub async fn reconnect( &mut self, user: Option<String>, ) -> Result<(), WebSocketError>

重连

pub fn set_reconnect_policy(&mut self, policy: RetryPolicy)

pub fn on_ws_log<F>(&mut self, hook: F)

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

pub async fn on_notice<F>(&self, listener: F)

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

监听通知消息事件

pub async fn on_data<F>(&self, listener: F)

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

监听普通消息事件

pub async fn on_revoke<F>(&self, listener: F)

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

监听消息撤回事件

pub async fn off(&self, event: ChatEventType)

移除监听

pub fn disconnect(&mut self)

断开连接

pub fn send_ws(&self, content: &str) -> Result<(), Error>

通过已连接的 chat-channel 发送私聊消息

该方法要求先调用 connect(..., Some(to_user)) 建立目标会话连接。

pub async fn list(&self) -> Result<Vec<ChatData>, Error>

获取有私聊用户列表第一条消息

返回 私聊消息列表

pub async fn history( &self, user: String, page: u32, size: u32, autoread: bool, ) -> Result<Vec<ChatData>, Error>

获取用户私聊历史消息

• page 页数
• size 每页消息数量
• autoread 是否自动标记为已读

返回 私聊消息列表

pub async fn mark_as_read(&self, user: String) -> Result<bool, Error>

标记用户消息已读

• user 用户名

返回 执行结果

pub async fn unread(&self) -> Result<Vec<ChatData>, Error>

获取未读消息

返回 未读消息列表

pub async fn revoke(&self, msg_id: &str) -> Result<bool, Error>

撤回私聊消息

• msgId 消息 ID

返回 执行结果