Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
Modifier and Type | Field and Description |
---|---|
static BackpressureOverflow.Strategy |
BackpressureOverflow.ON_OVERFLOW_DEFAULT
By default, signal a MissingBackressureException due to lack of requests.
|
static BackpressureOverflow.Strategy |
BackpressureOverflow.ON_OVERFLOW_DROP_LATEST
Drop the latest value.
|
static BackpressureOverflow.Strategy |
BackpressureOverflow.ON_OVERFLOW_DROP_OLDEST
Drop the oldest value in the buffer.
|
static BackpressureOverflow.Strategy |
BackpressureOverflow.ON_OVERFLOW_ERROR
Signal a MissingBackressureException due to lack of requests.
|
Modifier and Type | Method and Description |
---|---|
Observable<T> |
Observable.onBackpressureBuffer(long capacity,
Action0 onOverflow,
BackpressureOverflow.Strategy overflowStrategy)
Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to
a given amount of items until they can be emitted.
|
Copyright © 2022. All rights reserved.