Class ObservableConcatMapScheduler.ConcatMapDelayErrorObserver<T,​R>

  • All Implemented Interfaces:
    Observer<T>, Disposable, java.io.Serializable, java.lang.Runnable
    Enclosing class:
    ObservableConcatMapScheduler<T,​U>

    static final class ObservableConcatMapScheduler.ConcatMapDelayErrorObserver<T,​R>
    extends java.util.concurrent.atomic.AtomicInteger
    implements Observer<T>, Disposable, java.lang.Runnable