org.infinispan.iteration.impl

Class TransactionAwareEntryIterable<K,V>

java.lang.Object

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

org.infinispan.iteration.impl.TransactionAwareEntryIterable<K,V>

All Implemented Interfaces:

AutoCloseable, Iterable<CacheEntry<K,V>>, CloseableIterable<CacheEntry<K,V>>, EntryIterable<K,V>

public class TransactionAwareEntryIterable<K,V>
extends TransactionAwareCloseableIterable<K,V,V>
implements EntryIterable<K,V>

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 inherited from class org.infinispan.iteration.impl.TransactionAwareCloseableIterable

cache, converter, ctx, filter, iterable

Constructor Summary

Constructors

Constructor and Description
TransactionAwareEntryIterable(EntryIterable<K,V> entryIterable, KeyValueFilter<? super K,? super V> filter, TxInvocationContext<LocalTransaction> ctx, Cache<K,V> cache)

Method Summary

Modifier and Type	Method and Description
<C> CloseableIterable<CacheEntry<K,C>>	converter(Converter<? super K,? super V,C> converter) This returns a CloseableIterable that will change the type of the returned value for the entry using the already provided filter in addition to the converter.

Methods inherited from class org.infinispan.iteration.impl.TransactionAwareCloseableIterable

close, iterator

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

close, iterator

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

TransactionAwareEntryIterable

public TransactionAwareEntryIterable(EntryIterable<K,V> entryIterable,
                                     KeyValueFilter<? super K,? super V> filter,
                                     TxInvocationContext<LocalTransaction> ctx,
                                     Cache<K,V> cache)

Method Detail

converter

public <C> CloseableIterable<CacheEntry<K,C>> converter(Converter<? super K,? super V,C> converter)

Description copied from interface: EntryIterable

This returns a CloseableIterable that will change the type of the returned value for the entry using the already provided filter in addition to the converter.

Specified by:

converter in interface EntryIterable<K,V>

Type Parameters:

C - The type of the converted value

Parameters:

converter - The converter to apply to the iterator that is produced. Callbacks to to this converter will never provide a key or value that is null.

Returns:

A CloseableIterator that will use the given converter