reactive-streams-utils
reactive-streams-utils copied to clipboard
Async collectors
Currently we're using the JDK8 collector API for doing all terminal accumulations. It would be good to have an async alternative, eg AsyncCollector, where the accumulator and finisher functions return CompletionStage of a value when they are done. Then async alternatives of collect, reduce etc can be provided.
Note this could probably be implemented by a stateful mapCompletionStage.