Package io.servicetalk.concurrent.api

Class TestIterableToBlockingIterable<T>

java.lang.Object

io.servicetalk.concurrent.api.TestIterableToBlockingIterable<T>

All Implemented Interfaces:

BlockingIterable<T>, CloseableIterable<T>, java.lang.Iterable<T>

public class TestIterableToBlockingIterable<T>
extends java.lang.Object
implements BlockingIterable<T>

Nested Class Summary

Nested classes/interfaces inherited from interface io.servicetalk.concurrent.BlockingIterable

BlockingIterable.Processor<T>

Constructor Summary

Constructors

Constructor	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)

Method Summary

Modifier and Type	Method	Description
BlockingIterator<T>	iterator()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.servicetalk.concurrent.BlockingIterable

forEach, forEach, spliterator

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

TestIterableToBlockingIterable

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)

Method Detail

iterator

public BlockingIterator<T> iterator()

Specified by:

iterator in interface BlockingIterable<T>

Specified by:

iterator in interface CloseableIterable<T>

Specified by:

iterator in interface java.lang.Iterable<T>