/*
* Hibernate, Relational Persistence for Idiomatic Java
*
* License: GNU Lesser General Public License (LGPL), version 2.1 or later.
* See the lgpl.txt file in the root directory or <http://www.gnu.org/licenses/lgpl-2.1.html>.
*/
package org.hibernate.internal.util.collections;
import java.util.Iterator;
import java.util.List;
A JoinedIterable is an Iterable that wraps a number of Iterables. This class makes multiple iterables look like one to the caller. When any method from the Iterator interface is called on the Iterator object returned by iterator()
, the JoinedIterable will delegate to a single underlying Iterator. The JoinedIterable will invoke the iterator on each Iterable, in sequence, until all Iterators are exhausted. Author: Gail Badner (adapted from JoinedIterator)
/**
* A JoinedIterable is an Iterable that wraps a number of Iterables.
*
* This class makes multiple iterables look like one to the caller.
* When any method from the Iterator interface is called on the
* Iterator object returned by {@link #iterator()}, the JoinedIterable
* will delegate to a single underlying Iterator. The JoinedIterable will
* invoke the iterator on each Iterable, in sequence, until all Iterators
* are exhausted.
*
* @author Gail Badner (adapted from JoinedIterator)
*/
public class JoinedIterable<T> implements Iterable<T> {
private final TypeSafeJoinedIterator<T> iterator;
public JoinedIterable(List<Iterable<T>> iterables) {
if ( iterables == null ) {
throw new NullPointerException( "Unexpected null iterables argument" );
}
iterator = new TypeSafeJoinedIterator<T>( iterables );
}
public Iterator<T> iterator() {
return iterator;
}
private static class TypeSafeJoinedIterator<T> implements Iterator<T> {
// wrapped iterators
private List<Iterable<T>> iterables;
// index of current iterator in the wrapped iterators array
private int currentIterableIndex;
// the current iterator
private Iterator<T> currentIterator;
// the last used iterator
private Iterator<T> lastUsedIterator;
public TypeSafeJoinedIterator(List<Iterable<T>> iterables) {
this.iterables = iterables;
}
public boolean hasNext() {
updateCurrentIterator();
return currentIterator.hasNext();
}
public T next() {
updateCurrentIterator();
return currentIterator.next();
}
public void remove() {
updateCurrentIterator();
lastUsedIterator.remove();
}
// call this before any Iterator method to make sure that the current Iterator
// is not exhausted
@SuppressWarnings( {"unchecked"})
protected void updateCurrentIterator() {
if ( currentIterator == null) {
if( iterables.size() == 0 ) {
currentIterator = EmptyIterator.INSTANCE;
}
else {
currentIterator = iterables.get( 0 ).iterator();
}
// set last used iterator here, in case the user calls remove
// before calling hasNext() or next() (although they shouldn't)
lastUsedIterator = currentIterator;
}
while (! currentIterator.hasNext() && currentIterableIndex < iterables.size() - 1) {
currentIterableIndex++;
currentIterator = iterables.get( currentIterableIndex ).iterator();
}
}
}
}