Package one.util.streamex
Class UnorderedCancellableSpliterator<T,A>
- java.lang.Object
-
- one.util.streamex.Internals.CloneableSpliterator<A,UnorderedCancellableSpliterator<T,A>>
-
- one.util.streamex.UnorderedCancellableSpliterator<T,A>
-
- All Implemented Interfaces:
java.lang.Cloneable
,java.util.Spliterator<A>
class UnorderedCancellableSpliterator<T,A> extends Internals.CloneableSpliterator<A,UnorderedCancellableSpliterator<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.concurrent.atomic.AtomicBoolean
cancelled
private java.util.function.Predicate<A>
cancelPredicate
private java.util.function.BinaryOperator<A>
combiner
private boolean
flag
private java.util.concurrent.atomic.AtomicInteger
nPeers
private java.util.concurrent.ConcurrentLinkedQueue<A>
partialResults
private java.util.Spliterator<T>
source
private java.util.function.Supplier<A>
supplier
-
Constructor Summary
Constructors Constructor Description UnorderedCancellableSpliterator(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 int
characteristics()
private boolean
checkCancel(A acc)
long
estimateSize()
void
forEachRemaining(java.util.function.Consumer<? super A> action)
private boolean
handleCancel(java.util.function.Consumer<? super A> action, A acc)
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 volatile java.util.Spliterator<T> source
-
cancelPredicate
private final java.util.function.Predicate<A> cancelPredicate
-
supplier
private final java.util.function.Supplier<A> supplier
-
partialResults
private final java.util.concurrent.ConcurrentLinkedQueue<A> partialResults
-
cancelled
private final java.util.concurrent.atomic.AtomicBoolean cancelled
-
nPeers
private final java.util.concurrent.atomic.AtomicInteger nPeers
-
combiner
private final java.util.function.BinaryOperator<A> combiner
-
flag
private boolean flag
-
-
Method Detail
-
checkCancel
private boolean checkCancel(A acc)
-
tryAdvance
public boolean tryAdvance(java.util.function.Consumer<? super A> action)
-
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()
-
-