SSE Stream Resilience
Implements Redis-backed Server-Sent Events (SSE) management with heartbeat monitoring and automatic recovery to prevent silent stream failures.
This skill provides a robust framework for managing SSE streams by utilizing Redis as a central registry to track active connections. It solves critical real-time communication challenges such as silent client disconnects, lost terminal events, and server-side resource leaks. By integrating a background guardian process and a completion store, it ensures that users receive final event data even after network interruptions, making it ideal for production-grade AI chat interfaces and long-running data streams.
主要功能
01Completion store to persist terminal events for client recovery
0294 GitHub stars
03Automated background guardian process for resource cleanup
04Redis-based stream registry for distributed connection tracking
05Standardized TypeScript patterns for SSE endpoint resilience
06Heartbeat monitoring to detect and flag orphaned streams
使用场景
01Building reliable AI chat interfaces with streaming LLM responses
02Implementing live progress tracking for long-running background tasks
03Managing high-concurrency notification systems across multiple server instances