sse_processor 1.0.0+2

A pure Dart package for Server-Sent Events (SSE) delivery management

SSE Processor

一个纯Dart包，用于Server-Sent Events (SSE)的传递管理。

项目介绍

SSE Processor是一个专为Flutter应用设计的SSE处理库，它解决了在处理服务器发送事件流时的一系列问题，包括数据解析、速率控制、分发机制、优先级管理、缓存策略等。

为什么需要这个库

在处理AI生成数据的流式传输时，客户端通常会面临以下挑战：

解析问题：如何解析流式数据并转换为客户端可用的数据结构 速率控制：如何控制服务器不规则发送的流数据的展示速率 分发机制：如何将转换后的流数据分发到多个模块进行逻辑处理 优先级管理：如何在分发过程中考虑优先级 缓存策略：如何设计循环缓存池进行定时分发 自动清理：如何简化拦截器的注册和注销操作 分发状态控制：如何暂停/恢复分发和监控分发状态 生命周期管理：如何处理自动清理功能相关的生命周期回调 原生流桥接：如何与原生层的网络组件集成 连接状态管理：如何监控和管理SSE连接状态

特性

• 完整的SSE处理流程：从流数据解析到缓存、分发的全流程管理
• 灵活的拦截器机制：支持添加多个拦截器接收不同类型的SSE事件
• 智能缓存管理：提供循环缓存池和定时分发功能
• 连接状态监控：实时监控连接状态并通知观察者
• 拦截器自动清理：避免接收无用的SSE事件
• 自定义协议转换：支持不同业务场景的流数据格式转换
• 流过滤器：支持将单个SSE对象转换为多个SSE对象