Class BatchingSpliterator<T>

java.lang.Object

com.pivovarit.collectors.BatchingSpliterator<T>

All Implemented Interfaces:

Spliterator<List<T>>

final class BatchingSpliterator<T>
extends Object
implements Spliterator<List<T>>

Nested Class Summary

Nested classes/interfaces inherited from interface Spliterator

Spliterator.OfDouble, Spliterator.OfInt, Spliterator.OfLong, Spliterator.OfPrimitive<T,T_CONS,T_SPLITR>

Field Summary

Fields

Modifier and Type	Field	Description
private int	chunks
private int	chunkSize
private int	consumed
private final int	maxChunks
private final List<T>	source

Fields inherited from interface Spliterator

CONCURRENT, DISTINCT, IMMUTABLE, NONNULL, ORDERED, SIZED, SORTED, SUBSIZED

Constructor Summary

Constructors

Modifier	Constructor	Description
private	BatchingSpliterator(List<T> list, int batches)

Method Summary

Modifier and Type	Method	Description
private static <T> Stream<List<T>>	asSingletonListStream(List<T> list)
(package private) static <T,R> Function<List<T>,List<R>>	batching(Function<T,R> mapper)
int	characteristics()
long	estimateSize()
(package private) static <T> Stream<List<T>>	partitioned(List<T> list, int numberOfParts)
boolean	tryAdvance(Consumer<? super List<T>> action)
Spliterator<List<T>>	trySplit()

Methods inherited from class Object

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

Methods inherited from interface Spliterator

forEachRemaining, getComparator, getExactSizeIfKnown, hasCharacteristics

Field Details

source

private final List<T> source

maxChunks

private final int maxChunks

chunks

private int chunks

chunkSize

private int chunkSize

consumed

private int consumed

Constructor Details

BatchingSpliterator

private BatchingSpliterator(List<T> list,
 int batches)

Method Details

partitioned

static <T> Stream<List<T>> partitioned(List<T> list,
 int numberOfParts)

asSingletonListStream

private static <T> Stream<List<T>> asSingletonListStream(List<T> list)

batching

static <T,R> Function<List<T>,List<R>> batching(Function<T,R> mapper)

tryAdvance

public boolean tryAdvance(Consumer<? super List<T>> action)

Specified by:

tryAdvance in interface Spliterator<T>

trySplit

public Spliterator<List<T>> trySplit()

Specified by:

trySplit in interface Spliterator<T>

estimateSize

public long estimateSize()

Specified by:

estimateSize in interface Spliterator<T>

characteristics

public int characteristics()

Specified by:

characteristics in interface Spliterator<T>