Class BlockingFlowableLatest.LatestSubscriberIterator<T>

java.lang.Object
io.reactivex.rxjava3.subscribers.DisposableSubscriber<Notification<T>>
io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableLatest.LatestSubscriberIterator<T>
All Implemented Interfaces:
FlowableSubscriber<Notification<T>>, Disposable, Iterator<T>, org.reactivestreams.Subscriber<Notification<T>>
Enclosing class:
BlockingFlowableLatest<T>

static final class BlockingFlowableLatest.LatestSubscriberIterator<T> extends DisposableSubscriber<Notification<T>> implements Iterator<T>
Subscriber of source, iterator for output.
  • Field Details

  • Constructor Details

    • LatestSubscriberIterator

      LatestSubscriberIterator()
  • Method Details

    • onNext

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

      public void onError(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 Iterator<T>
    • next

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

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