Class OperatorOnBackpressureDrop<T>

java.lang.Object
rx.internal.operators.OperatorOnBackpressureDrop<T>
All Implemented Interfaces:
Func1<Subscriber<? super T>,Subscriber<? super T>>, Function, Observable.Operator<T,T>

public class OperatorOnBackpressureDrop<T> extends Object implements Observable.Operator<T,T>
  • Field Details

    • onDrop

      final Action1<? super T> onDrop
  • Constructor Details

    • OperatorOnBackpressureDrop

      OperatorOnBackpressureDrop()
    • OperatorOnBackpressureDrop

      public OperatorOnBackpressureDrop(Action1<? super T> onDrop)
  • Method Details