StreamConverters.javaCollector

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 javaCollector[T, R](collectorFactory: () ⇒ java.util.stream.Collector[T, _ <: Any, R]): Sink[T, Future[R]]

Description

@@@div { .callout }

@@@

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.