org.infinispan.stream.impl.interceptor

Class AbstractDelegatingEntryCacheSet<K,V>

java.lang.Object

org.infinispan.util.AbstractDelegatingCollection<E>

org.infinispan.util.AbstractDelegatingCloseableIteratorCollection<E>

org.infinispan.stream.impl.AbstractDelegatingCacheCollection<E>

org.infinispan.stream.impl.AbstractDelegatingCacheSet<CacheEntry<K,V>>

org.infinispan.stream.impl.interceptor.AbstractDelegatingEntryCacheSet<K,V>

Type Parameters:

K - key type of the cache

V - 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>>, CloseableIteratorCollection<CacheEntry<K,V>>, 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 and Description
protected	AbstractDelegatingEntryCacheSet(Cache<K,V> cache, CacheSet<CacheEntry<K,V>> set)

Method Summary

Modifier and Type	Method and 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.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.CloseableIteratorSet

spliterator

Methods inherited from interface java.util.Set

add, addAll, clear, contains, containsAll, equals, hashCode, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArray

Methods inherited from interface org.infinispan.commons.util.CloseableIteratorCollection

iterator

Methods inherited from interface java.util.Collection

removeIf

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

AbstractDelegatingEntryCacheSet

protected AbstractDelegatingEntryCacheSet(Cache<K,V> cache,
                                          CacheSet<CacheEntry<K,V>> set)

Method Detail

delegate

protected final CacheSet<CacheEntry<K,V>> delegate()

Specified by:

delegate in class AbstractDelegatingCacheSet<CacheEntry<K,V>>

stream

public CacheStream<CacheEntry<K,V>> stream()

Specified by:

stream in interface Collection<CacheEntry<K,V>>

Specified by:

stream in interface CacheCollection<CacheEntry<K,V>>

Specified by:

stream in class AbstractDelegatingCacheCollection<CacheEntry<K,V>>

parallelStream

public CacheStream<CacheEntry<K,V>> parallelStream()

Specified by:

parallelStream in interface Collection<CacheEntry<K,V>>

Specified by:

parallelStream in interface CacheCollection<CacheEntry<K,V>>

Specified by:

parallelStream in class AbstractDelegatingCacheCollection<CacheEntry<K,V>>

getStream

protected CacheStream<CacheEntry<K,V>> getStream(boolean parallel)