Class OnSubscribeConcatMap.ConcatMapSubscriber<T,​R>

    • Field Detail

      • delayErrorMode

        final int delayErrorMode
      • queue

        final java.util.Queue<java.lang.Object> queue
      • wip

        final java.util.concurrent.atomic.AtomicInteger wip
      • error

        final java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> error
      • done

        volatile boolean done
      • active

        volatile boolean active
    • Constructor Detail

      • ConcatMapSubscriber

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

      • onError

        public void onError​(java.lang.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
      • requestMore

        void requestMore​(long n)
      • innerNext

        void innerNext​(R value)
      • innerError

        void innerError​(java.lang.Throwable innerError,
                        long produced)
      • innerCompleted

        void innerCompleted​(long produced)
      • pluginError

        void pluginError​(java.lang.Throwable e)
      • drain

        void drain()
      • drainError

        void drainError​(java.lang.Throwable mapperError)