What problem does it solve? Writing correct streaming code in TypeScript requires handling backpressure, resource cleanup, concurrency, and encoding errors, and developers often misuse Effect Stream APIs or miss edge cases like split UTF-8 characters and unbounded collection. ## Core Features & Use Cases - Stream Creation and Transformation: Construct streams from iterables, paginated APIs, DOM events, Node.js readables, and async iterables, then transform them with map, filter, flatMap, grouping, debounce, and throttle. - Encoding and Decoding: Pipe streams through NDJSON and SchemaBinary codec channels for wire-format serialization with schema validation and error recovery. - Concurrency and Resource Safety: Merge, broadcast, and share streams with controlled fan-out, and manage resources with scoped acquisition and forkScoped consumers. - Use Case: Consume a paginated REST API with Stream.paginate, enrich each item concurrently with mapEffect, filter invalid entries, and write batches to a database with runForEach. ## Quick Start Ask the agent to build an Effect Stream pipeline that fetches all pages from a paginated API, transforms the results concurrently, and decodes NDJSON responses with schema validation.
