Class ParallelStreamCollector<T,R>

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 Classes

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

Nested classes/interfaces inherited from interface Collector

Collector.Characteristics

Field Summary

Fields

Modifier and Type	Field	Description
private final Set<Collector.Characteristics>	characteristics
private final CompletionStrategy<R>	completionStrategy
private final Dispatcher<R>	dispatcher
private final Function<T,R>	function
private static final EnumSet<Collector.Characteristics>	UNORDERED

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ParallelStreamCollector(Function<T,R> function, CompletionStrategy<R> completionStrategy, Set<Collector.Characteristics> characteristics, Dispatcher<R> dispatcher)

Method Summary

Modifier and Type	Method	Description
BiConsumer<List<CompletableFuture<R>>, T>	accumulator()
Set<Collector.Characteristics>	characteristics()
BinaryOperator<List<CompletableFuture<R>>>	combiner()
Function<List<CompletableFuture<R>>, Stream<R>>	finisher()
(package private) static <T,R> Collector<T, ?, Stream<R>>	streaming(Function<T,R> mapper)
(package private) static <T,R> Collector<T, ?, Stream<R>>	streaming(Function<T,R> mapper, int parallelism)
(package private) static <T,R> Collector<T, ?, Stream<R>>	streaming(Function<T,R> mapper, Executor executor, int parallelism)
(package private) static <T,R> Collector<T, ?, Stream<R>>	streamingOrdered(Function<T,R> mapper)
(package private) static <T,R> Collector<T, ?, Stream<R>>	streamingOrdered(Function<T,R> mapper, int parallelism)
(package private) static <T,R> Collector<T, ?, Stream<R>>	streamingOrdered(Function<T,R> mapper, Executor executor, 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

UNORDERED

private static final EnumSet<Collector.Characteristics> UNORDERED

function

private final Function<T,R> function

completionStrategy

private final CompletionStrategy<R> completionStrategy

characteristics

private final Set<Collector.Characteristics> characteristics

dispatcher

private final Dispatcher<R> dispatcher

Constructor Details

ParallelStreamCollector

private ParallelStreamCollector(Function<T,R> function,
 CompletionStrategy<R> completionStrategy,
 Set<Collector.Characteristics> characteristics,
 Dispatcher<R> dispatcher)

Method Details

supplier

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

Specified by:

supplier in interface Collector<T, List<CompletableFuture<R>>, Stream<R>>

accumulator

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

Specified by:

accumulator in interface Collector<T, List<CompletableFuture<R>>, Stream<R>>

combiner

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

Specified by:

combiner in interface Collector<T, List<CompletableFuture<R>>, Stream<R>>

finisher

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

Specified by:

finisher in interface Collector<T, List<CompletableFuture<R>>, Stream<R>>

characteristics

public Set<Collector.Characteristics> characteristics()

Specified by:

characteristics in interface Collector<T, List<CompletableFuture<R>>, Stream<R>>

streaming

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

streaming

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

streaming

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

streamingOrdered

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

streamingOrdered

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

streamingOrdered

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