Struct FlareClient 

pub struct FlareClient { /* private fields */ }

Flare 客户端

Implementations

impl FlareClient

pub async fn send_frame(&self, frame: &Frame) -> Result<()>

发送消息 Frame

pub async fn send_frame_and_wait( &self, frame: &Frame, timeout: Duration, ) -> Result<Frame>

发送并等待响应（按 message_id 匹配）

pub fn is_connected(&self) -> bool

检查是否已连接（native 同步；WASM 请用 Self::is_connected_async）

pub async fn is_connected_async(&self) -> bool

检查是否已连接（async，全平台）

pub async fn disconnect(self) -> Result<()>

断开连接

pub fn connection_id(&self) -> Option<String>

获取连接 ID（native 同步；WASM 请用 Self::connection_id_async）

pub async fn connection_id_async(&self) -> Option<String>

获取连接 ID（async，全平台）

pub async fn parser_snapshot(&self) -> MessageParser

获取协商后的消息解析器快照

pub fn active_protocol(&self) -> TransportProtocol

获取活动协议

pub async fn update_heartbeat_config(&self, config: HeartbeatConfig)

运行期替换心跳策略。

pub async fn set_heartbeat_app_state(&self, state: HeartbeatAppState)

更新应用前后台状态。移动端进入后台时可拉长心跳，回到前台时恢复较短心跳。

pub async fn set_heartbeat_nat_timeout(&self, timeout: Option<Duration>)

更新 NAT 空闲超时探测结果。传入 None 表示清除探测值。

pub async fn heartbeat_effective_interval(&self) -> Duration

当前实际心跳间隔。

pub async fn update_parser(&self, parser: MessageParser)

更新消息管道解析器（协商完成后调用）

pub async fn add_observer(&self, observer: Arc<dyn ConnectionObserver>)

添加连接观察者

观察者会收到连接事件（Connected、Disconnected、Error、Message）

Trait Implementations

impl Clone for FlareClient

fn clone(&self) -> FlareClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.