Class MaybeDelay.DelayMaybeObserver<T>

java.lang.Object
java.util.concurrent.atomic.AtomicReference<Disposable>
io.reactivex.rxjava3.internal.operators.maybe.MaybeDelay.DelayMaybeObserver<T>
All Implemented Interfaces:
MaybeObserver<T>, Disposable, Serializable, Runnable
Enclosing class:
MaybeDelay<T>

static final class MaybeDelay.DelayMaybeObserver<T> extends AtomicReference<Disposable> implements MaybeObserver<T>, Disposable, Runnable
  • Field Details

    • serialVersionUID

      private static final long serialVersionUID
      See Also:
    • downstream

      final MaybeObserver<? super T> downstream
    • delay

      final long delay
    • unit

      final TimeUnit unit
    • scheduler

      final Scheduler scheduler
    • delayError

      final boolean delayError
    • value

      T value
    • error

      Throwable error
  • Constructor Details

  • Method Details