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>

static final class BlockingFlowableNext.NextIterator<T> extends Object implements Iterator<T>
  • Field Details

    • 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 Throwable error
    • started

      private boolean started
  • Constructor Details

  • Method Details

    • hasNext

      public boolean hasNext()
      Specified by:
      hasNext in interface Iterator<T>
    • moveToNext

      private boolean moveToNext()
    • next

      public T next()
      Specified by:
      next in interface Iterator<T>
    • remove

      public void remove()
      Specified by:
      remove in interface Iterator<T>