Class BlockingObservableIterable<T>

java.lang.Object

io.reactivex.rxjava3.internal.operators.observable.BlockingObservableIterable<T>

All Implemented Interfaces:

Iterable<T>

public final class BlockingObservableIterable<T>
extends Object
implements Iterable<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	BlockingObservableIterable.BlockingObservableIterator<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final int	bufferSize
(package private) final ObservableSource<? extends T>	source

Constructor Summary

Constructors

Constructor	Description
BlockingObservableIterable(ObservableSource<? extends T> source, int bufferSize)

Method Summary

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

Methods inherited from class Object

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

Methods inherited from interface Iterable

forEach, spliterator

Field Details

source

final ObservableSource<? extends T> source

bufferSize

final int bufferSize

Constructor Details

BlockingObservableIterable

public BlockingObservableIterable(ObservableSource<? extends T> source,
 int bufferSize)

Method Details

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>