Class OnSubscribeConcatMap.ConcatMapSubscriber<T,R>

java.lang.Object
rx.Subscriber<T>
rx.internal.operators.OnSubscribeConcatMap.ConcatMapSubscriber<T,R>
All Implemented Interfaces:
Observer<T>, Subscription
Enclosing class:
OnSubscribeConcatMap<T,R>

static final class OnSubscribeConcatMap.ConcatMapSubscriber<T,R> extends Subscriber<T>
  • Field Details

  • Constructor Details

    • ConcatMapSubscriber

      public ConcatMapSubscriber(Subscriber<? super R> actual, Func1<? super T,? extends Observable<? extends R>> mapper, int prefetch, int delayErrorMode)
  • Method Details

    • onNext

      public void onNext(T t)
      Description copied from interface: Observer
      Provides the Observer with a new item to observe.

      The Observable may call this method 0 or more times.

      The Observable will not call this method again after it calls either Observer.onCompleted() or Observer.onError(java.lang.Throwable).

      Parameters:
      t - the item emitted by the Observable
    • onError

      public void onError(Throwable mainError)
      Description copied from interface: Observer
      Notifies the Observer that the Observable has experienced an error condition.

      If the Observable calls this method, it will not thereafter call Observer.onNext(T) or Observer.onCompleted().

      Parameters:
      mainError - the exception encountered by the Observable
    • onCompleted

      public void onCompleted()
      Description copied from interface: Observer
      Notifies the Observer that the Observable has finished sending push-based notifications.

      The Observable will not call this method if it calls Observer.onError(java.lang.Throwable).

    • requestMore

      void requestMore(long n)
    • innerNext

      void innerNext(R value)
    • innerError

      void innerError(Throwable innerError, long produced)
    • innerCompleted

      void innerCompleted(long produced)
    • pluginError

      void pluginError(Throwable e)
    • drain

      void drain()
    • drainError

      void drainError(Throwable mapperError)