Class OperatorOnBackpressureLatest<T>

java.lang.Object
rx.internal.operators.OperatorOnBackpressureLatest<T>
Type Parameters:
T - the value type
All Implemented Interfaces:
Func1<Subscriber<? super T>,Subscriber<? super T>>, Function, Observable.Operator<T,T>

public final class OperatorOnBackpressureLatest<T> extends Object implements Observable.Operator<T,T>
An operator which drops all but the last received value in case the downstream doesn't request more.
  • Constructor Details

    • OperatorOnBackpressureLatest

      public OperatorOnBackpressureLatest()
  • Method Details

    • instance

      public static <T> OperatorOnBackpressureLatest<T> instance()
      Returns a singleton instance of the OnBackpressureLatest operator since it is stateless.
      Type Parameters:
      T - the value type
      Returns:
      the single instanceof OperatorOnBackpressureLatest
    • call

      public Subscriber<? super T> call(Subscriber<? super T> child)
      Specified by:
      call in interface Func1<Subscriber<? super T>,Subscriber<? super T>>