java.lang.Object | ||
↳ | java.lang.Enum<E extends java.lang.Enum<E>> | |
↳ | io.reactivex.BackpressureStrategy |
Represents the options for applying backpressure to a source sequence.
Enum Values | |||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
BackpressureStrategy | BUFFER | Buffers all onNext values until the downstream consumes it. | |||||||||
BackpressureStrategy | DROP | Drops the most recent onNext value if the downstream can't keep up. | |||||||||
BackpressureStrategy | ERROR | Signals a MissingBackpressureException in case the downstream can't keep up. | |||||||||
BackpressureStrategy | LATEST | Keeps only the latest onNext value, overwriting any previous value if the downstream can't keep up. | |||||||||
BackpressureStrategy | MISSING | OnNext events are written without any buffering or dropping. |
Public Methods | |||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
static BackpressureStrategy | valueOf(String name) | ||||||||||
final static BackpressureStrategy[] | values() |
[Expand]
Inherited Methods | |||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
From class
java.lang.Enum
| |||||||||||
From class
java.lang.Object
| |||||||||||
From interface
java.lang.Comparable
|
Buffers all onNext values until the downstream consumes it.
Drops the most recent onNext value if the downstream can't keep up.
Signals a MissingBackpressureException in case the downstream can't keep up.
Keeps only the latest onNext value, overwriting any previous value if the downstream can't keep up.
OnNext events are written without any buffering or dropping. Downstream has to deal with any overflow.
Useful when one applies one of the custom-parameter onBackpressureXXX operators.