Class AsyncParallelCollector.BatchingCollectors

java.lang.Object

com.pivovarit.collectors.AsyncParallelCollector.BatchingCollectors

Enclosing class:

AsyncParallelCollector<T,R,C>

static final class AsyncParallelCollector.BatchingCollectors
extends Object

Constructor Summary

Constructors

Modifier	Constructor	Description
private	BatchingCollectors()

Method Summary

Modifier and Type	Method	Description
private 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)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BatchingCollectors

private BatchingCollectors()

Method Details

collectingWithCollector

static <T,R,RR>
Collector<T, ?, CompletableFuture<RR>> collectingWithCollector(Collector<R,?,RR> collector,
 Function<T,R> mapper,
 Executor executor,
 int parallelism)

collectingToStream

static <T,R>
Collector<T, ?, CompletableFuture<Stream<R>>> collectingToStream(Function<T,R> mapper,
 Executor executor,
 int parallelism)

batchingCollector

private static <T,R,RR>
Collector<T, ?, CompletableFuture<RR>> batchingCollector(Function<T,R> mapper,
 Executor executor,
 int parallelism,
 Function<Stream<R>, RR> finisher)