StreamConverters.javaCollectorParallelUnordered

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

Signature

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

Description

TODO: We would welcome help on contributing descriptions and examples, see: https://github.com/akka/akka/issues/25646

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.