Class 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 Detail

      • 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
    • Method Detail

      • hasNext

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

        private boolean moveToNext()
      • next

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

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