flare-core 1.0.2

A high-performance, reliable long-connection communication toolkit for Rust, supporting WebSocket and QUIC protocols with features like authentication, device management, serialization negotiation, and protocol racing.
Documentation
//! 消息处理模块
//!
//! 提供完整的消息处理功能,包括:
//! - 消息解析:序列化/反序列化、压缩/解压缩
//! - 消息处理:观察者模式的消息分发和处理
//! - 消息管道:统一的消息处理流程,支持中间件
//! - 中间件:日志、监控、验证等常用中间件

pub mod handler;
pub mod middleware;
pub mod parser;
pub mod pipeline;
pub mod processor;

// 重新导出常用类型,方便使用
pub use handler::{ArcMessageObserver, MessageEvent, MessageHandler, MessageObserver};
pub use middleware::{LogLevel, LoggingMiddleware, MetricsMiddleware, ValidationMiddleware};
pub use parser::{MessageParser, PRE_NEGOTIATION_PARSER};
pub use pipeline::{
    ArcMessageMiddleware, ArcMessageProcessor, MessageContext, MessageMiddleware, MessagePipeline,
    MessageProcessor,
};
pub use processor::{DelegateProcessor, FunctionProcessor};