Struct ObserverClientBuilder 

pub struct ObserverClientBuilder { /* private fields */ }

观察者模式客户端构建器

提供基本功能实现，使用 ConnectionObserver trait 处理连接事件和消息。

设计原则

• 公共逻辑统一处理：基于 HybridClient，共享所有核心能力
• 事件驱动：使用 ConnectionObserver trait 处理所有连接事件
• 灵活扩展：支持自定义观察器和事件处理器

使用方式

用户只需要实现 ConnectionObserver trait，处理消息、连接建立、断开、错误等事件。

Implementations

impl ObserverClientBuilder

pub fn new(server_url: impl Into<String>) -> Self

创建新的观察者模式构建器

pub fn with_event_handler( self, event_handler: Arc<dyn ClientEventHandler>, ) -> Self

设置事件处理器（可选，用于自定义业务逻辑）

pub fn with_observer(self, observer: Arc<dyn ConnectionObserver>) -> Self

设置观察者（必须）

pub fn with_protocol(self, protocol: TransportProtocol) -> Self

设置传输协议

pub fn with_protocol_race(self, protocols: Vec<TransportProtocol>) -> Self

启用多协议竞速

协议列表的顺序就是优先级顺序，前面的协议优先级更高

pub fn with_protocol_url(self, protocol: TransportProtocol, url: String) -> Self

为特定协议设置服务器地址

pub fn with_user_id(self, user_id: String) -> Self

设置用户 ID

pub fn with_format(self, format: SerializationFormat) -> Self

设置序列化格式

pub fn with_compression(self, compression: CompressionAlgorithm) -> Self

设置压缩算法

pub fn with_heartbeat(self, heartbeat: HeartbeatConfig) -> Self

设置心跳配置

pub fn with_tls(self, tls: TlsConfig) -> Self

设置 TLS 配置

pub fn with_connect_timeout(self, timeout: Duration) -> Self

设置连接超时

pub fn with_reconnect_interval(self, interval: Duration) -> Self

设置重连间隔

pub fn with_max_reconnect_attempts(self, max: Option<u32>) -> Self

设置最大重连次数

pub fn enable_router(self) -> Self

启用消息路由

启用后，可以通过 ClientCore 的 router 方法注册消息处理器

pub fn with_device_info(self, device_info: DeviceInfo) -> Self

设置设备信息（用于协商和设备管理）

pub fn with_token(self, token: String) -> Self

设置 Token（用于认证，如果服务端启用认证，必须提供）

pub async fn build_with_race(self) -> Result<ObserverClient>

构建客户端（使用协议竞速）

pub fn build(self) -> Result<ObserverClient>

构建客户端