Class CompletionOrderSpliterator<T>

java.lang.Object

com.pivovarit.collectors.CompletionOrderSpliterator<T>

All Implemented Interfaces:

Spliterator<T>

final class CompletionOrderSpliterator<T>
extends Object
implements Spliterator<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 final BlockingQueue<CompletableFuture<T>>	completed
private final int	initialSize
private int	remaining

Fields inherited from interface Spliterator

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

Constructor Summary

Constructors

Constructor	Description
CompletionOrderSpliterator(List<CompletableFuture<T>> futures)

Method Summary

Modifier and Type	Method	Description
int	characteristics()
long	estimateSize()
private CompletableFuture<T>	nextCompleted()
boolean	tryAdvance(Consumer<? super T> action)
Spliterator<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

initialSize

private final int initialSize

completed

private final BlockingQueue<CompletableFuture<T>> completed

remaining

private int remaining

Constructor Details

CompletionOrderSpliterator

CompletionOrderSpliterator(List<CompletableFuture<T>> futures)

Method Details

tryAdvance

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

Specified by:

tryAdvance in interface Spliterator<T>

nextCompleted

private CompletableFuture<T> nextCompleted()

trySplit

public Spliterator<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>