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 ClassesModifier and TypeClassDescription(package private) static final class
Nested classes/interfaces inherited from interface java.util.stream.Collector
Collector.Characteristics
-
Field Summary
Fields -
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
AsyncParallelCollector
(Function<T, R> task, Dispatcher<R> dispatcher, Function<Stream<R>, C> finalizer) -
Method Summary
Modifier and TypeMethodDescription(package private) static <T,
R, RR> Collector <T, ?, CompletableFuture<RR>> asyncCollector
(Function<T, R> mapper, Executor executor, Function<Stream<R>, RR> finisher) (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) combiner()
finisher()
(package private) static void
requireValidParallelism
(int parallelism) supplier()
-
Field Details
-
dispatcher
-
task
-
finalizer
-
-
Constructor Details
-
AsyncParallelCollector
-
-
Method Details
-
supplier
-
combiner
-
accumulator
- Specified by:
accumulator
in interfaceCollector<T,
R, C>
-
finisher
-
characteristics
- Specified by:
characteristics
in interfaceCollector<T,
R, C>
-
combine
-
collectingToStream
-
collectingToStream
static <T,R> Collector<T,?, collectingToStreamCompletableFuture<Stream<R>>> (Function<T, R> mapper, int parallelism) -
collectingToStream
static <T,R> Collector<T,?, collectingToStreamCompletableFuture<Stream<R>>> (Function<T, R> mapper, Executor executor, int parallelism) -
collectingWithCollector
static <T,R, Collector<T,RR> ?, collectingWithCollectorCompletableFuture<RR>> (Collector<R, ?, RR> collector, Function<T, R> mapper) -
collectingWithCollector
static <T,R, Collector<T,RR> ?, collectingWithCollectorCompletableFuture<RR>> (Collector<R, ?, RR> collector, Function<T, R> mapper, int parallelism) -
collectingWithCollector
static <T,R, Collector<T,RR> ?, collectingWithCollectorCompletableFuture<RR>> (Collector<R, ?, RR> collector, Function<T, R> mapper, Executor executor, int parallelism) -
requireValidParallelism
static void requireValidParallelism(int parallelism) -
asyncCollector
-