org.infinispan.distribution.util

Class ReadOnlySegmentAwareIterator<E>

java.lang.Object

org.infinispan.distribution.util.ReadOnlySegmentAwareIterator<E>

All Implemented Interfaces:

Iterator<E>

Direct Known Subclasses:

ReadOnlySegmentAwareEntryIterator

public class ReadOnlySegmentAwareIterator<E>
extends Object
implements Iterator<E>

Iterator implementation that shows a read only view of the provided iterator by only allowing values that map to a given segment using the provided consistent hash.

This iterator is used with the other various SegmentAware Collections such as ReadOnlySegmentAwareCollection

Since:

7.2

Author:

wburns

Field Summary

Fields

Modifier and Type	Field and Description
protected IntSet	allowedSegments
protected Iterator<E>	iter
protected E	next
protected LocalizedCacheTopology	topology

Constructor Summary

Constructors

Constructor and Description
ReadOnlySegmentAwareIterator(Iterator<E> iter, LocalizedCacheTopology topology, IntSet allowedSegments)

Method Summary

Modifier and Type	Method and Description
protected E	findNext()
boolean	hasNext()
E	next()
void	remove()
protected boolean	valueAllowed(Object obj)

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

iter

protected final Iterator<E> iter

topology

protected final LocalizedCacheTopology topology

allowedSegments

protected final IntSet allowedSegments

next

protected E next

Constructor Detail

ReadOnlySegmentAwareIterator

public ReadOnlySegmentAwareIterator(Iterator<E> iter,
                                    LocalizedCacheTopology topology,
                                    IntSet allowedSegments)

Method Detail

valueAllowed

protected boolean valueAllowed(Object obj)

findNext

protected E findNext()

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<E>

next

public E next()

Specified by:

next in interface Iterator<E>

remove

public void remove()

Specified by:

remove in interface Iterator<E>