Why use Redis for SSE management instead of local memory?

Redis allows you to manage stream states across multiple server nodes in a distributed environment, ensuring that a guardian process on one instance can clean up or recover streams from another.

Can clients recover missed completion events?

Yes, terminal events are stored in a dedicated Redis completion store for a configurable window (e.g., 5 minutes), allowing clients to poll for the final result if the connection drops.

How does the heartbeat mechanism prevent resource leaks?

The server expects periodic updates to a stream's timestamp in Redis; if a stream stops sending heartbeats, the Guardian process identifies it as stale and triggers cleanup.

Is this skill compatible with modern frontend frameworks?

Yes, it includes client-side patterns compatible with React, Vue, and vanilla JavaScript for handling reconnections and recovery logic.

SSE Stream Resilience

Name: SSE Stream Resilience
Author: majiayu000

bymajiayu000

•

API開発

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

What are Skills?·How to Install

Install with 🐟 Skill.Fish

npx skillfish add majiayu000/claude-skill-registry api

For use in Claude.ai and ChatGPT

Download Skill