Class ConcatMapXMainObserver<T>

    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      (package private) void clearValue()
      Override this to clear values when the downstream disposes.
      void dispose()
      Dispose the resource, the operation should be idempotent.
      (package private) abstract void disposeInner()
      Typically, this should be inner.dispose().
      (package private) abstract void drain()
      Implement the serialized inner subscribing and value emission here.
      boolean isDisposed()
      Returns true if this resource has been disposed.
      void onComplete()
      Notifies the Observer that the Observable has finished sending push-based notifications.
      void onError​(java.lang.Throwable t)
      Notifies the Observer that the Observable has experienced an error condition.
      void onNext​(T t)
      Provides the Observer with a new item to observe.
      void onSubscribe​(Disposable d)
      Provides the Observer with the means of cancelling (disposing) the connection (channel) with the Observable in both synchronous (from within Observer.onNext(Object)) and asynchronous manner.
      (package private) abstract void onSubscribeDownstream()
      Typically, this should be downstream.onSubscribe(this).
      • Methods inherited from class java.util.concurrent.atomic.AtomicInteger

        accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
      • Methods inherited from class java.lang.Number

        byteValue, shortValue
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Constructor Detail

      • ConcatMapXMainObserver

        public ConcatMapXMainObserver​(int prefetch,
                                      ErrorMode errorMode)
    • Method Detail

      • onError

        public final void onError​(java.lang.Throwable t)
        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.onComplete().

        Specified by:
        onError in interface Observer<T>
        Parameters:
        t - the exception encountered by the Observable
      • dispose

        public final void dispose()
        Description copied from interface: Disposable
        Dispose the resource, the operation should be idempotent.
        Specified by:
        dispose in interface Disposable
      • isDisposed

        public final boolean isDisposed()
        Description copied from interface: Disposable
        Returns true if this resource has been disposed.
        Specified by:
        isDisposed in interface Disposable
        Returns:
        true if this resource has been disposed
      • clearValue

        void clearValue()
        Override this to clear values when the downstream disposes.
      • onSubscribeDownstream

        abstract void onSubscribeDownstream()
        Typically, this should be downstream.onSubscribe(this).
      • disposeInner

        abstract void disposeInner()
        Typically, this should be inner.dispose().
      • drain

        abstract void drain()
        Implement the serialized inner subscribing and value emission here.