Class AsyncParallelCollector<T,R,C>

java.lang.Object

com.pivovarit.collectors.AsyncParallelCollector<T,R,C>

All Implemented Interfaces:

Collector<T, List<CompletableFuture<R>>, CompletableFuture<C>>

final class AsyncParallelCollector<T,R,C>
extends Object
implements Collector<T, List<CompletableFuture<R>>, CompletableFuture<C>>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	AsyncParallelCollector.BatchingCollectors

Nested classes/interfaces inherited from interface Collector

Collector.Characteristics

Field Summary

Fields

Modifier and Type	Field	Description
private final Dispatcher<R>	dispatcher
private final Function<Stream<R>, C>	finalizer
private final Function<T,R>	task

Constructor Summary

Constructors

Modifier	Constructor	Description
private	AsyncParallelCollector(Function<T,R> task, Dispatcher<R> dispatcher, Function<Stream<R>, C> finalizer)

Method Summary

Modifier and Type	Method	Description
BiConsumer<List<CompletableFuture<R>>, T>	accumulator()
(package private) static <T,R,RR> Collector<T, ?, CompletableFuture<RR>>	asyncCollector(Function<T,R> mapper, Executor executor, Function<Stream<R>, RR> finisher)
Set<Collector.Characteristics>	characteristics()
(package private) static <T,R> Collector<T, ?, CompletableFuture<Stream<R>>>	collectingToStream(Function<T,R> mapper)
(package private) static <T,R> Collector<T, ?, CompletableFuture<Stream<R>>>	collectingToStream(Function<T,R> mapper, int parallelism)
(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)
(package private) static <T,R,RR> Collector<T, ?, CompletableFuture<RR>>	collectingWithCollector(Collector<R,?,RR> collector, Function<T,R> mapper, 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)
private static <T> CompletableFuture<Stream<T>>	combine(List<CompletableFuture<T>> futures)
BinaryOperator<List<CompletableFuture<R>>>	combiner()
Function<List<CompletableFuture<R>>, CompletableFuture<C>>	finisher()
(package private) static void	requireValidParallelism(int parallelism)
Supplier<List<CompletableFuture<R>>>	supplier()

Methods inherited from class Object

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

Field Details

dispatcher

private final Dispatcher<R> dispatcher

task

private final Function<T,R> task

finalizer

private final Function<Stream<R>, C> finalizer

Constructor Details

AsyncParallelCollector

private AsyncParallelCollector(Function<T,R> task,
 Dispatcher<R> dispatcher,
 Function<Stream<R>, C> finalizer)

Method Details

supplier

public Supplier<List<CompletableFuture<R>>> supplier()

Specified by:

supplier in interface Collector<T,R,C>

combiner

public BinaryOperator<List<CompletableFuture<R>>> combiner()

Specified by:

combiner in interface Collector<T,R,C>

accumulator

public BiConsumer<List<CompletableFuture<R>>, T> accumulator()

Specified by:

accumulator in interface Collector<T,R,C>

finisher

public Function<List<CompletableFuture<R>>, CompletableFuture<C>> finisher()

Specified by:

finisher in interface Collector<T,R,C>

characteristics

public Set<Collector.Characteristics> characteristics()

Specified by:

characteristics in interface Collector<T,R,C>

combine

private static <T> CompletableFuture<Stream<T>> combine(List<CompletableFuture<T>> futures)

collectingToStream

static <T,R>
Collector<T, ?, CompletableFuture<Stream<R>>> collectingToStream(Function<T,R> mapper)

collectingToStream

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

collectingToStream

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

collectingWithCollector

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

collectingWithCollector

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

collectingWithCollector

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

requireValidParallelism

static void requireValidParallelism(int parallelism)

asyncCollector

static <T,R,RR>
Collector<T, ?, CompletableFuture<RR>> asyncCollector(Function<T,R> mapper,
 Executor executor,
 Function<Stream<R>, RR> finisher)