-
- All Implemented Interfaces:
-
java.io.Serializable
,java.lang.Comparable
public enum Emitter.BackpressureMode
Options to handle backpressure in the emitter.
-
-
Enum Constant Summary
Enum Constants Enum Constant Description NONE
ERROR
Signals a rx.exceptions.MissingBackpressureException if the downstream can't keep up.
BUFFER
Buffers (unbounded) all onNext calls until the downstream can consume them.
DROP
Drops the incoming onNext value if the downstream can't keep up.
LATEST
Keeps the latest onNext value and overwrites it with newer ones until the downstreamcan consume it.
-
Method Summary
Modifier and Type Method Description static Array<Emitter.BackpressureMode>
values()
static Emitter.BackpressureMode
valueOf(String name)
-
-
Method Detail
-
values
static Array<Emitter.BackpressureMode> values()
-
valueOf
static Emitter.BackpressureMode valueOf(String name)
-
-
-
-