Class ParallelStreamCollector.BatchingCollectors

java.lang.Object

com.pivovarit.collectors.ParallelStreamCollector.BatchingCollectors

Enclosing class:

ParallelStreamCollector<T,R>

static final class ParallelStreamCollector.BatchingCollectors
extends Object

Constructor Summary

Constructors

Modifier	Constructor	Description
private	BatchingCollectors()

Method Summary

Modifier and Type	Method	Description
private static <T,R> Collector<T, ?, Stream<R>>	batchingCollector(Function<T,R> mapper, Executor executor, 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, Executor executor, int parallelism)
private static <T,R> Collector<T, Stream.Builder<R>, Stream<R>>	syncCollector(Function<T,R> mapper)

Methods inherited from class Object

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

Constructor Details

BatchingCollectors

private BatchingCollectors()

Method Details

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,
 Executor executor,
 int parallelism)

batchingCollector

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

syncCollector

private static <T,R>
Collector<T, Stream.Builder<R>, Stream<R>> syncCollector(Function<T,R> mapper)