Class BlockingObservableNext.NextIterator<T>
- java.lang.Object
-
- io.reactivex.rxjava3.internal.operators.observable.BlockingObservableNext.NextIterator<T>
-
- All Implemented Interfaces:
java.util.Iterator<T>
- Enclosing class:
- BlockingObservableNext<T>
static final class BlockingObservableNext.NextIterator<T> extends java.lang.Object implements java.util.Iterator<T>
-
-
Field Summary
Fields Modifier and Type Field Description private java.lang.Throwable
error
private boolean
hasNext
private boolean
isNextConsumed
private ObservableSource<T>
items
private T
next
private BlockingObservableNext.NextObserver<T>
observer
private boolean
started
-
Constructor Summary
Constructors Constructor Description NextIterator(ObservableSource<T> items, BlockingObservableNext.NextObserver<T> observer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
hasNext()
private boolean
moveToNext()
T
next()
void
remove()
-
-
-
Field Detail
-
observer
private final BlockingObservableNext.NextObserver<T> observer
-
items
private final ObservableSource<T> items
-
next
private T next
-
hasNext
private boolean hasNext
-
isNextConsumed
private boolean isNextConsumed
-
error
private java.lang.Throwable error
-
started
private boolean started
-
-
Constructor Detail
-
NextIterator
NextIterator(ObservableSource<T> items, BlockingObservableNext.NextObserver<T> observer)
-
-