org.infinispan.iteration.impl

Class RemovableEntryIterator<K,V,C>

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, Iterator<CacheEntry<K,C>>, CloseableIterator<CacheEntry<K,C>>

Direct Known Subclasses:

TransactionAwareCloseableIterator

public class RemovableEntryIterator<K,V,C>
extends Object
implements CloseableIterator<CacheEntry<K,C>>

A CloseableIterator implementation that allows for a CloseableIterator that doesn't allow remove operations to implement remove by delegating the call to the provided cache to remove the previously read value.

Since:

7.0

Author:

wburns

Field Summary

Fields

Modifier and Type	Field and Description
protected Cache<K,V>	cache
protected CacheEntry<K,C>	currentValue
protected CacheEntry<K,C>	previousValue
protected CloseableIterator<CacheEntry<K,V>>	realIterator

Constructor Summary

Constructors

Constructor and Description
RemovableEntryIterator(CloseableIterator<CacheEntry<K,V>> realIterator, Cache<K,V> cache, boolean initIterator)

Method Summary

Modifier and Type	Method and Description
void	close()
protected CacheEntry<K,C>	getNextFromIterator()
boolean	hasNext()
CacheEntry<K,C>	next()
void	remove()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Field Detail

realIterator

protected final CloseableIterator<CacheEntry<K,V>> realIterator

cache

protected final Cache<K,V> cache

previousValue

protected CacheEntry<K,C> previousValue

currentValue

protected CacheEntry<K,C> currentValue

Constructor Detail

RemovableEntryIterator

public RemovableEntryIterator(CloseableIterator<CacheEntry<K,V>> realIterator,
                              Cache<K,V> cache,
                              boolean initIterator)

Method Detail

getNextFromIterator

protected CacheEntry<K,C> getNextFromIterator()

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<CacheEntry<K,C>>

next

public CacheEntry<K,C> next()

Specified by:

next in interface Iterator<CacheEntry<K,C>>

remove

public void remove()

Specified by:

remove in interface Iterator<CacheEntry<K,C>>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

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