org.infinispan.iteration.impl

Class TransactionAwareCloseableIterable<K,V,C>

java.lang.Object

org.infinispan.iteration.impl.TransactionAwareCloseableIterable<K,V,C>

All Implemented Interfaces:

AutoCloseable, Iterable<CacheEntry<K,C>>, CloseableIterable<CacheEntry<K,C>>

Direct Known Subclasses:

TransactionAwareEntryIterable

public class TransactionAwareCloseableIterable<K,V,C>
extends Object
implements CloseableIterable<CacheEntry<K,C>>

CloseableIterable implementation that will enhance another CloseableIterable to use the provided context values in the iteration process properly. That is context values will take precendence over values found from the iterator.

Since:

7.0

Author:

wburns

Field Summary

Fields

Modifier and Type	Field and Description
protected Cache<K,?>	cache
protected Converter<? super K,? super V,? extends C>	converter
protected TxInvocationContext<LocalTransaction>	ctx
protected KeyValueFilter<? super K,? super V>	filter
protected CloseableIterable<CacheEntry<K,C>>	iterable

Constructor Summary

Constructors

Constructor and Description
TransactionAwareCloseableIterable(CloseableIterable<CacheEntry<K,C>> iterable, KeyValueFilter<? super K,? super V> filter, Converter<? super K,? super V,? extends C> converter, TxInvocationContext<LocalTransaction> ctx, Cache<K,?> cache)

Method Summary

Modifier and Type	Method and Description
void	close()
CloseableIterator<CacheEntry<K,C>>	iterator()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

iterable

protected final CloseableIterable<CacheEntry<K,C>> iterable

ctx

protected final TxInvocationContext<LocalTransaction> ctx

cache

protected final Cache<K,?> cache

filter

protected final KeyValueFilter<? super K,? super V> filter

converter

protected final Converter<? super K,? super V,? extends C> converter

Constructor Detail

TransactionAwareCloseableIterable

public TransactionAwareCloseableIterable(CloseableIterable<CacheEntry<K,C>> iterable,
                                         KeyValueFilter<? super K,? super V> filter,
                                         Converter<? super K,? super V,? extends C> converter,
                                         TxInvocationContext<LocalTransaction> ctx,
                                         Cache<K,?> cache)

Method Detail

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CloseableIterable<CacheEntry<K,C>>

iterator

public CloseableIterator<CacheEntry<K,C>> iterator()

Specified by:

iterator in interface Iterable<CacheEntry<K,C>>

Specified by:

iterator in interface CloseableIterable<CacheEntry<K,C>>