java.lang.Object | ||
↳ | java.lang.Enum<E extends java.lang.Enum<E>> | |
↳ | io.reactivex.annotations.BackpressureKind |
Enumeration for various kinds of backpressure support.
Enum Values | |||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
BackpressureKind | ERROR | The operator will emit a MissingBackpressureException if the downstream didn't request enough or in time. | |||||||||
BackpressureKind | FULL | The operator fully supports backpressure and may coordinate downstream requests with upstream requests through batching, arbitration or by other means. | |||||||||
BackpressureKind | NONE | The operator ignores all kinds of backpressure and may overflow the downstream. | |||||||||
BackpressureKind | PASS_THROUGH | The backpressure-related requests pass through this operator without change. | |||||||||
BackpressureKind | SPECIAL | The operator performs special backpressure management; see the associated javadoc. | |||||||||
BackpressureKind | UNBOUNDED_IN | The operator requests Long.MAX_VALUE from upstream but respects the backpressure of the downstream. |
Public Methods | |||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
static BackpressureKind | valueOf(String name) | ||||||||||
final static BackpressureKind[] | values() |
[Expand]
Inherited Methods | |||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
![]() | |||||||||||
![]() | |||||||||||
![]() |
The operator will emit a MissingBackpressureException if the downstream didn't request enough or in time.
The operator fully supports backpressure and may coordinate downstream requests with upstream requests through batching, arbitration or by other means.
The operator ignores all kinds of backpressure and may overflow the downstream.
The backpressure-related requests pass through this operator without change.
The operator performs special backpressure management; see the associated javadoc.
The operator requests Long.MAX_VALUE from upstream but respects the backpressure of the downstream.