Class BlockingFlowableNext.NextIterator<T>
java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableNext.NextIterator<T>
- All Implemented Interfaces:
Iterator<T>
- Enclosing class:
BlockingFlowableNext<T>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate Throwable
private boolean
private boolean
private final org.reactivestreams.Publisher
<? extends T> private T
private boolean
private final BlockingFlowableNext.NextSubscriber
<T> -
Constructor Summary
ConstructorsConstructorDescriptionNextIterator
(org.reactivestreams.Publisher<? extends T> items, BlockingFlowableNext.NextSubscriber<T> subscriber) -
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
-
subscriber
-
items
-
next
-
hasNext
private boolean hasNext -
isNextConsumed
private boolean isNextConsumed -
error
-
started
private boolean started
-
-
Constructor Details
-
NextIterator
NextIterator(org.reactivestreams.Publisher<? extends T> items, BlockingFlowableNext.NextSubscriber<T> subscriber)
-
-
Method Details