Struct ServerMessageWrapper 

pub struct ServerMessageWrapper { /* private fields */ }

服务端事件包装器

将 DefaultServerMessageObserver 的功能直接集成到 ConnectionHandler 中， 提供统一的消息和连接事件处理

Implementations

impl ServerMessageWrapper

pub fn new( event_handler: Arc<dyn ServerEventHandler>, connection_manager: Option<Arc<ConnectionManager>>, device_manager: Option<Arc<DeviceManager>>, parser: MessageParser, ) -> Self

创建新的服务端消息包装器

参数

• event_handler: 事件处理器，用于处理所有事件和消息
• connection_manager: 连接管理器（可选，用于发送响应）
• device_manager: 设备管理器（可选，用于设备管理）
• parser: 消息解析器（用于序列化响应）

Trait Implementations

impl Clone for ServerMessageWrapper

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConnectionHandler for ServerMessageWrapper

实现连接处理的接口

fn handle_frame<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, frame: &'life1 Frame, connection_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Frame>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

处理消息

fn on_connect<'life0, 'life1, 'async_trait>( &'life0 self, connection_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

处理连接建立事件

fn on_disconnect<'life0, 'life1, 'async_trait>( &'life0 self, connection_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

处理连接断开事件