rill

Functions take and return channels, enabling Unix-like piping that reduces boilerplate and enhances code clarity, as shown in the quick start example with chained Map and ForEach operations.

Each operation allows specifying concurrency levels, such as parallel mapping with configurable worker counts, giving precise control over resource usage without manual goroutine management.

Errors automatically flow through pipelines and can be handled in a single place via blocking functions like Err or ForEach, simplifying error handling compared to scattered error channels.

With zero external dependencies and a small API, Rill is easy to integrate into existing Go projects without adding bloat, as emphasized in the features section.

Supports batching, ordered fan-in, and flatMap for complex scenarios like real-time data processing with timeout-based batching, demonstrated in the README examples.