Class ObservableElementAt.ElementAtObserver<T>

java.lang.Object
io.reactivex.rxjava3.internal.operators.observable.ObservableElementAt.ElementAtObserver<T>
All Implemented Interfaces:
Observer<T>, Disposable
Enclosing class:
ObservableElementAt<T>

static final class ObservableElementAt.ElementAtObserver<T> extends Object implements Observer<T>, Disposable
  • Field Details

    • downstream

      final Observer<? super T> downstream
    • index

      final long index
    • defaultValue

      final T defaultValue
    • errorOnFewer

      final boolean errorOnFewer
    • upstream

      Disposable upstream
    • count

      long count
    • done

      boolean done
  • Constructor Details

    • ElementAtObserver

      ElementAtObserver(Observer<? super T> actual, long index, T defaultValue, boolean errorOnFewer)
  • Method Details