org.infinispan.stream.impl.interceptor

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 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.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.CacheCollection

localPublisher, localPublisher

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()

Description copied from interface: CloseableIteratorCollection

This stream should be explicitly closed after it has been used. Failure to do so could cause resources to not be freed properly

Specified by:

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

Specified by:

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

Specified by:

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

Overrides:

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

parallelStream

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

Description copied from interface: CloseableIteratorCollection

This stream should be explicitly closed after it has been used. Failure to do so could cause resources to not be freed properly

Specified by:

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

Specified by:

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

Specified by:

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

Overrides:

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

getStream

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