public class OperatorOnBackpressureBuffer<T> extends Objectimplements Observable .Operator <T ,T>
| Constructor and Description |
|---|
OperatorOnBackpressureBuffer(long capacity)
|
OperatorOnBackpressureBuffer(long capacity, Action0
|
| Modifier and Type | Method and Description |
|---|---|
Subscriber |
call(Subscriber
|
static <T> OperatorOnBackpressureBuffer |
instance()
|
public OperatorOnBackpressureBuffer(long capacity)
public OperatorOnBackpressureBuffer(long capacity,
Action0 onOverflow) public static <T> OperatorOnBackpressureBuffer<T> instance()
public Subscriber<? super T> call(Subscriber <? super T> child)