Package one.util.streamex
Class OrderedCancellableSpliterator<T,A>
- java.lang.Object
-
- one.util.streamex.Internals.CloneableSpliterator<A,OrderedCancellableSpliterator<T,A>>
-
- one.util.streamex.OrderedCancellableSpliterator<T,A>
-
- All Implemented Interfaces:
java.lang.Cloneable
,java.util.Spliterator<A>
final class OrderedCancellableSpliterator<T,A> extends Internals.CloneableSpliterator<A,OrderedCancellableSpliterator<T,A>>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface java.util.Spliterator
java.util.Spliterator.OfDouble, java.util.Spliterator.OfInt, java.util.Spliterator.OfLong, java.util.Spliterator.OfPrimitive<T extends java.lang.Object,T_CONS extends java.lang.Object,T_SPLITR extends java.util.Spliterator.OfPrimitive<T,T_CONS,T_SPLITR>>
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.function.BiConsumer<A,? super T>
accumulator
private java.util.function.Predicate<A>
cancelPredicate
private java.util.function.BinaryOperator<A>
combiner
private boolean
localCancelled
private java.lang.Object
lock
private A
payload
private OrderedCancellableSpliterator<T,A>
prefix
private java.util.Spliterator<T>
source
private OrderedCancellableSpliterator<T,A>
suffix
private java.util.function.Supplier<A>
supplier
-
Constructor Summary
Constructors Constructor Description OrderedCancellableSpliterator(java.util.Spliterator<T> source, java.util.function.Supplier<A> supplier, java.util.function.BiConsumer<A,? super T> accumulator, java.util.function.BinaryOperator<A> combiner, java.util.function.Predicate<A> cancelPredicate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
cancelSuffix()
int
characteristics()
long
estimateSize()
void
forEachRemaining(java.util.function.Consumer<? super A> action)
boolean
tryAdvance(java.util.function.Consumer<? super A> action)
java.util.Spliterator<A>
trySplit()
-
Methods inherited from class one.util.streamex.Internals.CloneableSpliterator
doClone
-
-
-
-
Field Detail
-
source
private java.util.Spliterator<T> source
-
lock
private final java.lang.Object lock
-
cancelPredicate
private final java.util.function.Predicate<A> cancelPredicate
-
combiner
private final java.util.function.BinaryOperator<A> combiner
-
supplier
private final java.util.function.Supplier<A> supplier
-
localCancelled
private volatile boolean localCancelled
-
prefix
private volatile OrderedCancellableSpliterator<T,A> prefix
-
suffix
private volatile OrderedCancellableSpliterator<T,A> suffix
-
payload
private A payload
-
-
Method Detail
-
tryAdvance
public boolean tryAdvance(java.util.function.Consumer<? super A> action)
-
cancelSuffix
private void cancelSuffix()
-
forEachRemaining
public void forEachRemaining(java.util.function.Consumer<? super A> action)
-
trySplit
public java.util.Spliterator<A> trySplit()
-
estimateSize
public long estimateSize()
-
characteristics
public int characteristics()
-
-