Package rx.internal.operators
Class BlockingOperatorNext.NextIterator<T>
- java.lang.Object
-
- rx.internal.operators.BlockingOperatorNext.NextIterator<T>
-
- All Implemented Interfaces:
java.util.Iterator<T>
- Enclosing class:
- BlockingOperatorNext
static final class BlockingOperatorNext.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 Observable<? extends T>
items
private T
next
private BlockingOperatorNext.NextObserver<T>
observer
private boolean
started
-
Constructor Summary
Constructors Constructor Description NextIterator(Observable<? extends T> items, BlockingOperatorNext.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 BlockingOperatorNext.NextObserver<T> observer
-
items
private final Observable<? extends 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(Observable<? extends T> items, BlockingOperatorNext.NextObserver<T> observer)
-
-