Module parallel.collectors
Package com.pivovarit.collectors
Class AsyncParallelCollector.BatchingCollectors
java.lang.Object
com.pivovarit.collectors.AsyncParallelCollector.BatchingCollectors
- Enclosing class:
AsyncParallelCollector<T,
R, C>
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate static <T,
R, RR> Collector <T, ?, CompletableFuture<RR>> batchingCollector
(Function<T, R> mapper, Executor executor, int parallelism, Function<Stream<R>, RR> finisher) (package private) static <T,
R> Collector <T, ?, CompletableFuture<Stream<R>>> collectingToStream
(Function<T, R> mapper, Executor executor, int parallelism) (package private) static <T,
R, RR> Collector <T, ?, CompletableFuture<RR>> collectingWithCollector
(Collector<R, ?, RR> collector, Function<T, R> mapper, Executor executor, int parallelism)
-
Constructor Details
-
BatchingCollectors
private BatchingCollectors()
-
-
Method Details
-
collectingWithCollector
static <T,R, Collector<T,RR> ?, collectingWithCollectorCompletableFuture<RR>> (Collector<R, ?, RR> collector, Function<T, R> mapper, Executor executor, int parallelism) -
collectingToStream
static <T,R> Collector<T,?, collectingToStreamCompletableFuture<Stream<R>>> (Function<T, R> mapper, Executor executor, int parallelism) -
batchingCollector
-