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 javaCollector[T, R](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.