Class BlockingFlowableLatest.LatestSubscriberIterator<T>

    • Field Detail

      • notify

        final java.util.concurrent.Semaphore notify
      • value

        final java.util.concurrent.atomic.AtomicReference<Notification<T>> value
    • Constructor Detail

      • LatestSubscriberIterator

        LatestSubscriberIterator()
    • Method Detail

      • onNext

        public void onNext​(Notification<T> args)
        Specified by:
        onNext in interface org.reactivestreams.Subscriber<T>
      • onError

        public void onError​(java.lang.Throwable e)
        Specified by:
        onError in interface org.reactivestreams.Subscriber<T>
      • onComplete

        public void onComplete()
        Specified by:
        onComplete in interface org.reactivestreams.Subscriber<T>
      • hasNext

        public boolean hasNext()
        Specified by:
        hasNext in interface java.util.Iterator<T>
      • 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>