java.lang.Object
com.pivovarit.collectors.ParallelStreamCollector<T,R>
- All Implemented Interfaces:
Collector<T,
List<CompletableFuture<R>>, Stream<R>>
class ParallelStreamCollector<T,R>
extends Object
implements Collector<T,List<CompletableFuture<R>>,Stream<R>>
-
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
FieldsModifier and TypeFieldDescriptionprivate final Set
<Collector.Characteristics> private final CompletionStrategy
<R> private final Dispatcher
<R> private static final EnumSet
<Collector.Characteristics> -
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
ParallelStreamCollector
(Function<T, R> function, CompletionStrategy<R> completionStrategy, Set<Collector.Characteristics> characteristics, Dispatcher<R> dispatcher) -
Method Summary
Modifier and TypeMethodDescriptioncombiner()
finisher()
streamingOrdered
(Function<T, R> mapper) streamingOrdered
(Function<T, R> mapper, int parallelism) streamingOrdered
(Function<T, R> mapper, Executor executor, int parallelism) supplier()
-
Field Details
-
UNORDERED
-
function
-
completionStrategy
-
characteristics
-
dispatcher
-
-
Constructor Details
-
ParallelStreamCollector
private ParallelStreamCollector(Function<T, R> function, CompletionStrategy<R> completionStrategy, Set<Collector.Characteristics> characteristics, Dispatcher<R> dispatcher)
-
-
Method Details
-
supplier
-
accumulator
- Specified by:
accumulator
in interfaceCollector<T,
List<CompletableFuture<R>>, Stream<R>>
-
combiner
-
finisher
-
characteristics
- Specified by:
characteristics
in interfaceCollector<T,
List<CompletableFuture<R>>, Stream<R>>
-
streaming
-
streaming
-
streaming
-
streamingOrdered
-
streamingOrdered
-
streamingOrdered
-