Uses of Interface
org.infinispan.commons.util.CloseableIterator
-
Packages that use CloseableIterator Package Description org.infinispan.commons.util Commons package providing various utility classesorg.infinispan.interceptors.distribution Interceptors dealing with command replication in distributed/replicated mode.org.infinispan.server.hotrod org.infinispan.util General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and collections and containers designed to supplement the JDK-provided containers. -
-
Uses of CloseableIterator in org.infinispan.commons.util
Classes in org.infinispan.commons.util that implement CloseableIterator Modifier and Type Class Description class
CloseableIteratorMapper<E,S>
Deprecated.since 9.3 users can just useIteratorMapper
as it handles CloseableIterators nowclass
ConcatIterator<E>
Iterator that concatenates a bunch of iterables into 1 big iterator.class
FilterIterator<E>
Iterator that also filters out entries based on the provided predicate.class
IteratorMapper<E,S>
A iterator that maps each value to the output of the Function.class
RemovableCloseableIterator<C>
A CloseableIterator implementation that allows for a CloseableIterator that doesn't allow remove operations to implement remove by delegating the call to the provided consumer to remove the previously read value.Fields in org.infinispan.commons.util declared as CloseableIterator Modifier and Type Field Description protected CloseableIterator<C>
RemovableCloseableIterator. realIterator
Methods in org.infinispan.commons.util that return CloseableIterator Modifier and Type Method Description CloseableIterator<E>
CloseableIterable. iterator()
CloseableIterator<E>
CloseableIteratorCollection. iterator()
CloseableIterator<E>
CloseableIteratorCollectionAdapter. iterator()
static <E> CloseableIterator<E>
Closeables. iterator(Iterator<? extends E> iterator)
Creates a closeable iterator from the given iterator that does nothing when close is called.static <R> CloseableIterator<R>
Closeables. iterator(BaseStream<R,Stream<R>> stream)
Creates a closeable iterator that when closed will close the underlying stream as wellMethods in org.infinispan.commons.util with parameters of type CloseableIterator Modifier and Type Method Description static <E> CloseableSpliterator<E>
Closeables. spliterator(CloseableIterator<? extends E> iterator, long size, int characteristics)
Takes a provided closeable iterator and wraps it appropriately so it can be used as a closeable spliterator that will close the iterator when the spliterator is closed.static <E> Stream<E>
Closeables. stream(CloseableIterator<E> iterator, boolean parallel, long size, int characteristics)
Creates a stream that when closed will also close the underlying iteratorConstructors in org.infinispan.commons.util with parameters of type CloseableIterator Constructor Description RemovableCloseableIterator(CloseableIterator<C> realIterator, Consumer<? super C> consumer)
-
Uses of CloseableIterator in org.infinispan.interceptors.distribution
Methods in org.infinispan.interceptors.distribution that return CloseableIterator Modifier and Type Method Description CloseableIterator<CacheEntry<K,V>>
DistributionBulkInterceptor.BackingEntrySet. iterator()
CloseableIterator<K>
DistributionBulkInterceptor.BackingKeySet. iterator()
-
Uses of CloseableIterator in org.infinispan.server.hotrod
Methods in org.infinispan.server.hotrod with parameters of type CloseableIterator Modifier and Type Method Description io.netty.buffer.ByteBuf
AbstractEncoder1x. bulkGetKeysResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CloseableIterator<byte[]> iterator)
io.netty.buffer.ByteBuf
VersionedEncoder. bulkGetKeysResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CloseableIterator<byte[]> iterator)
-
Uses of CloseableIterator in org.infinispan.util
Classes in org.infinispan.util that implement CloseableIterator Modifier and Type Class Description class
CloseableSuppliedIterator<E>
class
LazyConcatIterator<E>
Iterator implementation that will return all entries from the first iterator.Methods in org.infinispan.util that return CloseableIterator Modifier and Type Method Description CloseableIterator<E>
AbstractDelegatingCloseableIteratorCollection. iterator()
CloseableIterator<E>
AbstractDelegatingCloseableIteratorSet. iterator()
CloseableIterator<R>
CacheCollectionMapper. iterator()
Deprecated.CloseableIterator<R>
CacheSetMapper. iterator()
static <E> CloseableIterator<E>
Closeables. iterator(org.reactivestreams.Publisher<E> publisher, int fetchSize)
Converts aPublisher
to aCloseableIterator
by utilizing items fetched into an array and refetched as they are consumed from the iterator.CloseableIterator<R>
WriteableCacheCollectionMapper. iterator()
Constructors in org.infinispan.util with parameters of type CloseableIterator Constructor Description LazyConcatIterator(CloseableIterator<E> first, Supplier<? extends CloseableIterator<E>> supplier)
Constructor parameters in org.infinispan.util with type arguments of type CloseableIterator Constructor Description LazyConcatIterator(CloseableIterator<E> first, Supplier<? extends CloseableIterator<E>> supplier)
-