| Interface | Description |
|---|---|
| LazyResultConsumer<T> |
Interface that defines the rules for Collecting results from Infinite SimpleReact Streams
|
| Class | Description |
|---|---|
| BatchingCollector<T> |
This class allows a Batch of completable futures to be processed before collecting their results, to increase
parallelism.
|
| Blocker<U> | |
| EmptyCollector<T> |
A collector that periodically joins active completablefutures
but does not store the results
|
| IncrementalReducer<T> |
Perform incremental (optionally parallel) reduction on a reactiveStream
|
| MaxActive | |
| SamplingCollector<T> |
Class that allows client code to only collect a sample of results from an Infinite SimpleReact Stream
The SamplingCollector won't collect results itself, but hand of control to a consumer that can when Sampling triggered.
|