Class AbstractDelegatingEntryCacheSet<K,V>
- java.lang.Object
-
- org.infinispan.commons.util.AbstractDelegatingCollection<E>
-
- org.infinispan.util.AbstractDelegatingCloseableIteratorCollection<E>
-
- org.infinispan.util.AbstractDelegatingCacheCollection<E>
-
- org.infinispan.util.AbstractDelegatingCacheSet<CacheEntry<K,V>>
-
- org.infinispan.stream.impl.interceptor.AbstractDelegatingEntryCacheSet<K,V>
-
- Type Parameters:
K
- key type of the cacheV
- value type of the cache
- All Implemented Interfaces:
Iterable<CacheEntry<K,V>>
,Collection<CacheEntry<K,V>>
,Set<CacheEntry<K,V>>
,CacheCollection<CacheEntry<K,V>>
,CacheSet<CacheEntry<K,V>>
,org.infinispan.commons.util.CloseableIteratorCollection<CacheEntry<K,V>>
,org.infinispan.commons.util.CloseableIteratorSet<CacheEntry<K,V>>
public abstract class AbstractDelegatingEntryCacheSet<K,V> extends AbstractDelegatingCacheSet<CacheEntry<K,V>>
Abstract cache entry set that delegates to the underlying cache for stream usage
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
AbstractDelegatingEntryCacheSet(Cache<K,V> cache, CacheSet<CacheEntry<K,V>> set)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected CacheSet<CacheEntry<K,V>>
delegate()
protected CacheStream<CacheEntry<K,V>>
getStream(boolean parallel)
CacheStream<CacheEntry<K,V>>
parallelStream()
CacheStream<CacheEntry<K,V>>
stream()
-
Methods inherited from class org.infinispan.util.AbstractDelegatingCloseableIteratorCollection
iterator, spliterator
-
Methods inherited from class org.infinispan.commons.util.AbstractDelegatingCollection
add, addAll, clear, contains, containsAll, forEach, isEmpty, remove, removeAll, removeIf, retainAll, size, toArray, toArray
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.infinispan.commons.util.CloseableIteratorCollection
iterator, spliterator
-
Methods inherited from interface java.util.Collection
removeIf, toArray
-
-
-
-
Method Detail
-
delegate
protected final CacheSet<CacheEntry<K,V>> delegate()
- Specified by:
delegate
in classAbstractDelegatingCacheSet<CacheEntry<K,V>>
-
stream
public CacheStream<CacheEntry<K,V>> stream()
- Specified by:
stream
in interfaceCacheCollection<K>
- Specified by:
stream
in interfaceorg.infinispan.commons.util.CloseableIteratorCollection<K>
- Specified by:
stream
in interfaceCollection<K>
- Overrides:
stream
in classAbstractDelegatingCacheCollection<CacheEntry<K,V>>
-
parallelStream
public CacheStream<CacheEntry<K,V>> parallelStream()
- Specified by:
parallelStream
in interfaceCacheCollection<K>
- Specified by:
parallelStream
in interfaceorg.infinispan.commons.util.CloseableIteratorCollection<K>
- Specified by:
parallelStream
in interfaceCollection<K>
- Overrides:
parallelStream
in classAbstractDelegatingCacheCollection<CacheEntry<K,V>>
-
getStream
protected CacheStream<CacheEntry<K,V>> getStream(boolean parallel)
-
-