Class OperatorOnBackpressureBuffer<T>

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

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

  • Constructor Details

    • OperatorOnBackpressureBuffer

      OperatorOnBackpressureBuffer()
    • OperatorOnBackpressureBuffer

      public OperatorOnBackpressureBuffer(long capacity)
      Construct a new instance that will handle overflows with ON_OVERFLOW_DEFAULT, providing the following behavior config:
      Parameters:
      capacity - the max number of items to be admitted in the buffer, must be greater than 0.
    • OperatorOnBackpressureBuffer

      public OperatorOnBackpressureBuffer(long capacity, Action0 onOverflow)
      Construct a new instance that will handle overflows with ON_OVERFLOW_DEFAULT, providing the following behavior config:
      Parameters:
      capacity - the max number of items to be admitted in the buffer, must be greater than 0.
      onOverflow - the Action0 to execute when the buffer overflows, may be null.
    • OperatorOnBackpressureBuffer

      public OperatorOnBackpressureBuffer(long capacity, Action0 onOverflow, BackpressureOverflow.Strategy overflowStrategy)
      Construct a new instance feeding the following behavior config:
      Parameters:
      capacity - the max number of items to be admitted in the buffer, must be greater than 0.
      onOverflow - the Action0 to execute when the buffer overflows, may be null.
      overflowStrategy - the BackpressureOverflow.Strategy to handle overflows, it must not be null.
  • Method Details