public class ParallelIterable<T> extends CloseableGroup implements CloseableIterable<T>
CloseableIterable.ConcatCloseableIterable<E>
Constructor and Description |
---|
ParallelIterable(java.lang.Iterable<? extends java.lang.Iterable<T>> iterables,
java.util.concurrent.ExecutorService workerPool) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<T> |
iterator()
Returns a closeable iterator over elements of type
T . |
addCloseable, addCloseable, close, setSuppressCloseFailure
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
combine, concat, count, empty, filter, filter, transform, whenComplete, withNoopClose, withNoopClose
public ParallelIterable(java.lang.Iterable<? extends java.lang.Iterable<T>> iterables, java.util.concurrent.ExecutorService workerPool)
public CloseableIterator<T> iterator()
CloseableIterable
T
.iterator
in interface java.lang.Iterable<T>
iterator
in interface CloseableIterable<T>
CloseableIterator
.