Class BlockingObservableNext.NextIterator<T>
java.lang.Object
io.reactivex.rxjava3.internal.operators.observable.BlockingObservableNext.NextIterator<T>
- All Implemented Interfaces:
Iterator<T>
- Enclosing class:
BlockingObservableNext<T>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate Throwable
private boolean
private boolean
private final ObservableSource
<T> private T
private final BlockingObservableNext.NextObserver
<T> private boolean
-
Constructor Summary
ConstructorsConstructorDescriptionNextIterator
(ObservableSource<T> items, BlockingObservableNext.NextObserver<T> observer) -
Method Summary
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface java.util.Iterator
forEachRemaining
-
Field Details
-
observer
-
items
-
next
-
hasNext
private boolean hasNext -
isNextConsumed
private boolean isNextConsumed -
error
-
started
private boolean started
-
-
Constructor Details
-
NextIterator
NextIterator(ObservableSource<T> items, BlockingObservableNext.NextObserver<T> observer)
-
-
Method Details