Collect all input elements using a Java
Sink which materializes into a
CompletionStage which will be completed with a result of the Java
Collector transformation and reduction operations.
Given a stream of numbers we can collect the numbers into a collection with the
final List<Integer> list = Arrays.asList(1, 2, 3);
CompletionStage<List<Integer>> result =
Reactive Streams semantics
cancels when the
Collector throws an exception
backpressures when the
Collector’s previous accumulation is still in progress
Found an error in this documentation? The source code for this page can be found here
Please feel free to edit and contribute a pull request.