effect-patterns-streams

What problem does it solve?

This Skill provides a curated set of Effect-TS streaming patterns to help developers design robust, lazy, and composable data pipelines for streams. It reduces boilerplate and guides best practices for streaming with Effect-TS.

Core Features & Use Cases

• Backpressure and throttling to control producer/consumer rates.
• Windowing and grouping (tumbling/sliding windows, groupBy) for per-key aggregations.
• Stateful stream analytics via scan and fold to maintain running statistics.
• Resource-safe streams using bracket and scope to ensure cleanup.
• Advanced transformations (demux, chunking, custom operators) for complex pipelines.
• Error handling (catch, retry, fallback) to keep streams resilient.

Quick Start

Start by loading the Streams skill and running a simple pipeline that creates a Stream of events and applies map/filter, then uses scan to track running totals. No external setup is required; just reference the Skill in your project and follow the step-by-step example in the Skill guide.