1 个仓库
Transducers that group stream elements into batches and emit them only when the transducer produces output.
Distinct from Stream Aggregation: Distinct from Stream Aggregation: focuses on synchronous batching via transducers, not terminal collection of all elements.
Explore 1 awesome GitHub repository matching software engineering & architecture · Synchronous Aggregators. Refine with filters or upvote what's useful.
ZIO is a functional effect system for the JVM that models asynchronous and concurrent programs as pure, composable values with typed error handling and dependency injection. Its core identity is built on fiber-based concurrency, where lightweight, non-blocking fibers execute millions of concurrent tasks with structured lifecycle management, and a dual-channel error model that separates expected business failures from unexpected system defects at compile time. The system provides effect-typed dependency injection through a layer-based dependency graph, pull-based reactive stream processing with
Provides synchronous stream aggregation using transducers for batching.