Class 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 java.lang.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 Detail

      • OperatorOnBackpressureLatest

        public OperatorOnBackpressureLatest()
    • Method Detail

      • 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