| java.lang.Object | ||
| ↳ | java.lang.Enum<E extends java.lang.Enum<E>> | |
| ↳ | io.reactivex.BackpressureStrategy | |
Class Overview
Represents the options for applying backpressure to a source sequence.
Summary
| 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
| |||||||||||
Enum Values
public static final BackpressureStrategy BUFFER
Buffers all onNext values until the downstream consumes it.
public static final BackpressureStrategy DROP
Drops the most recent onNext value if the downstream can't keep up.
public static final BackpressureStrategy ERROR
Signals a MissingBackpressureException in case the downstream can't keep up.
public static final BackpressureStrategy LATEST
Keeps only the latest onNext value, overwriting any previous value if the downstream can't keep up.
public static final BackpressureStrategy MISSING
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.