public class TestIterableToBlockingIterable<T> extends java.lang.Object implements BlockingIterable<T>
BlockingIterable.Processor<T>
Constructor and Description |
---|
TestIterableToBlockingIterable(java.lang.Iterable<T> iterable,
java.util.function.BiConsumer<java.lang.Long,java.util.concurrent.TimeUnit> hashNextConsumer,
java.util.function.BiConsumer<java.lang.Long,java.util.concurrent.TimeUnit> nextConsumer,
java.lang.AutoCloseable closeable) |
Modifier and Type | Method and Description |
---|---|
BlockingIterator<T> |
iterator() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, forEach, spliterator
public TestIterableToBlockingIterable(java.lang.Iterable<T> iterable, java.util.function.BiConsumer<java.lang.Long,java.util.concurrent.TimeUnit> hashNextConsumer, java.util.function.BiConsumer<java.lang.Long,java.util.concurrent.TimeUnit> nextConsumer, java.lang.AutoCloseable closeable)
public BlockingIterator<T> iterator()
iterator
in interface BlockingIterable<T>
iterator
in interface CloseableIterable<T>
iterator
in interface java.lang.Iterable<T>