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:
Cloneable
,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
Spliterator.OfDouble, Spliterator.OfInt, Spliterator.OfLong, Spliterator.OfPrimitive<T extends Object,
T_CONS extends Object, T_SPLITR extends Spliterator.OfPrimitive<T, T_CONS, T_SPLITR>> -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final BiConsumer<A,
? super T> private final AtomicBoolean
private final BinaryOperator<A>
private boolean
private final AtomicInteger
private final ConcurrentLinkedQueue<A>
private Spliterator<T>
Fields inherited from interface java.util.Spliterator
CONCURRENT, DISTINCT, IMMUTABLE, NONNULL, ORDERED, SIZED, SORTED, SUBSIZED
-
Constructor Summary
ConstructorsConstructorDescriptionUnorderedCancellableSpliterator
(Spliterator<T> source, Supplier<A> supplier, BiConsumer<A, ? super T> accumulator, BinaryOperator<A> combiner, Predicate<A> cancelPredicate) -
Method Summary
Modifier and TypeMethodDescriptionint
private boolean
checkCancel
(A acc) long
void
forEachRemaining
(Consumer<? super A> action) private boolean
handleCancel
(Consumer<? super A> action, A acc) boolean
tryAdvance
(Consumer<? super A> action) trySplit()
Methods inherited from class one.util.streamex.Internals.CloneableSpliterator
doClone
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface java.util.Spliterator
getComparator, getExactSizeIfKnown, hasCharacteristics
-
Field Details
-
source
-
accumulator
-
cancelPredicate
-
supplier
-
partialResults
-
cancelled
-
nPeers
-
combiner
-
flag
private boolean flag
-
-
Constructor Details
-
UnorderedCancellableSpliterator
UnorderedCancellableSpliterator(Spliterator<T> source, Supplier<A> supplier, BiConsumer<A, ? super T> accumulator, BinaryOperator<A> combiner, Predicate<A> cancelPredicate)
-
-
Method Details
-
checkCancel
-
handleCancel
-
tryAdvance
-
forEachRemaining
-
trySplit
-
estimateSize
public long estimateSize() -
characteristics
public int characteristics()
-