Create a sink which materializes into a Future CompletionStage which will be completed with a result of the Java 8 Collector transformation and reduction operations.

Additional Sink and Source converters


def javaCollectorParallelUnordered[T, R](parallelism: Int)(collectorFactory: () =>[T, _ <: Any, R]): Sink[T, Future[R]]


TODO: We would welcome help on contributing descriptions and examples, see:

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.