Class BlockingFlowableNext.NextIterator<T>
- java.lang.Object
-
- io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableNext.NextIterator<T>
-
- All Implemented Interfaces:
java.util.Iterator<T>
- Enclosing class:
- BlockingFlowableNext<T>
static final class BlockingFlowableNext.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 org.reactivestreams.Publisher<? extends T>
items
private T
next
private boolean
started
private BlockingFlowableNext.NextSubscriber<T>
subscriber
-
Constructor Summary
Constructors Constructor Description NextIterator(org.reactivestreams.Publisher<? extends T> items, BlockingFlowableNext.NextSubscriber<T> subscriber)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
hasNext()
private boolean
moveToNext()
T
next()
void
remove()
-
-
-
Field Detail
-
subscriber
private final BlockingFlowableNext.NextSubscriber<T> subscriber
-
items
private final org.reactivestreams.Publisher<? 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(org.reactivestreams.Publisher<? extends T> items, BlockingFlowableNext.NextSubscriber<T> subscriber)
-
-