Class IteratorAsSpliterator<T>
- java.lang.Object
-
- org.infinispan.stream.impl.spliterators.IteratorAsSpliterator<T>
-
- All Implemented Interfaces:
AutoCloseable
,Spliterator<T>
,org.infinispan.commons.util.CloseableSpliterator<T>
public class IteratorAsSpliterator<T> extends Object implements org.infinispan.commons.util.CloseableSpliterator<T>
A Spliterator using the provided iterator for supplying values. Splits occur start at the batch size. Each split gets subsequently bigger by increasing by the original split size. The batch size will never become higher than the configured max batch size
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
IteratorAsSpliterator.Builder<T>
-
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
-
Fields inherited from interface java.util.Spliterator
CONCURRENT, DISTINCT, IMMUTABLE, NONNULL, ORDERED, SIZED, SORTED, SUBSIZED
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
characteristics()
void
close()
long
estimateSize()
void
forEachRemaining(Consumer<? super T> action)
Comparator<? super T>
getComparator()
boolean
tryAdvance(Consumer<? super T> action)
Spliterator<T>
trySplit()
-
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
getExactSizeIfKnown, hasCharacteristics
-
-
-
-
Method Detail
-
trySplit
public Spliterator<T> trySplit()
- Specified by:
trySplit
in interfaceSpliterator<T>
-
forEachRemaining
public void forEachRemaining(Consumer<? super T> action)
- Specified by:
forEachRemaining
in interfaceSpliterator<T>
-
tryAdvance
public boolean tryAdvance(Consumer<? super T> action)
- Specified by:
tryAdvance
in interfaceSpliterator<T>
-
estimateSize
public long estimateSize()
- Specified by:
estimateSize
in interfaceSpliterator<T>
-
characteristics
public int characteristics()
- Specified by:
characteristics
in interfaceSpliterator<T>
-
getComparator
public Comparator<? super T> getComparator()
- Specified by:
getComparator
in interfaceSpliterator<T>
-
close
public void close()
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceorg.infinispan.commons.util.CloseableSpliterator<T>
-
-