Package rx.internal.operators
Class BlockingOperatorNext.NextIterator<T>
java.lang.Object
rx.internal.operators.BlockingOperatorNext.NextIterator<T>
- All Implemented Interfaces:
Iterator<T>
- Enclosing class:
BlockingOperatorNext
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate Throwable
private boolean
private boolean
private final Observable
<? extends T> private T
private final BlockingOperatorNext.NextObserver
<T> private boolean
-
Constructor Summary
ConstructorsConstructorDescriptionNextIterator
(Observable<? extends T> items, BlockingOperatorNext.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(Observable<? extends T> items, BlockingOperatorNext.NextObserver<T> observer)
-
-
Method Details