effect-stream

What problem does it solve?

Pull-based data streams that are lazily evaluated and capable of backpressure, enabling scalable processing of potentially unbounded sequences while ensuring resources are managed safely.

Core Features & Use Cases

• Lazy generation of streams from data sources (iterables, cursors) with built-in backpressure.
• Support for common stream operations: map, filter, flatMap, and async variants, plus merging and batching.
• Safe resource-scoped iteration via acquireRelease to tie lifecycle to consumption.

Quick Start

Start by creating a Stream from an iterable or a lazy source and begin processing with map and run methods.