public class OperatorOnBackpressureBuffer<T> extends Object implements Observable.Operator<T,T>
Constructor and Description |
---|
OperatorOnBackpressureBuffer(long capacity)
Construct a new instance that will handle overflows with
ON_OVERFLOW_DEFAULT , providing the
following behavior config: |
OperatorOnBackpressureBuffer(long capacity,
Action0 onOverflow)
Construct a new instance that will handle overflows with
ON_OVERFLOW_DEFAULT , providing the
following behavior config: |
OperatorOnBackpressureBuffer(long capacity,
Action0 onOverflow,
BackpressureOverflow.Strategy overflowStrategy)
Construct a new instance feeding the following behavior config:
|
Modifier and Type | Method and Description |
---|---|
Subscriber<? super T> |
call(Subscriber<? super T> child) |
static <T> OperatorOnBackpressureBuffer<T> |
instance() |
public OperatorOnBackpressureBuffer(long capacity)
ON_OVERFLOW_DEFAULT
, providing the
following behavior config:capacity
- the max number of items to be admitted in the buffer, must be greater than 0.public OperatorOnBackpressureBuffer(long capacity, Action0 onOverflow)
ON_OVERFLOW_DEFAULT
, providing the
following behavior config: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.public OperatorOnBackpressureBuffer(long capacity, Action0 onOverflow, BackpressureOverflow.Strategy overflowStrategy)
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.public static <T> OperatorOnBackpressureBuffer<T> instance()
public Subscriber<? super T> call(Subscriber<? super T> child)
call
in interface Func1<Subscriber<? super T>,Subscriber<? super T>>
Copyright © 2017. All rights reserved.