| Modifier and Type | Field and Description |
|---|---|
| public static final BackpressureKind | ERROR
The operator will emit a MissingBackpressureException if the downstream didn't request enough or in time. |
| public static final BackpressureKind | FULL
The operator fully supports backpressure and may coordinate downstream requests with upstream requests through batching, arbitration or by other means. |
| public static final BackpressureKind | NONE
The operator ignores all kinds of backpressure and may overflow the downstream. |
| public static final BackpressureKind | PASS_THROUGH
The backpressure-related requests pass through this operator without change. |
| public static final BackpressureKind | SPECIAL
The operator performs special backpressure management; see the associated javadoc. |
| public static final BackpressureKind | UNBOUNDED_IN
The operator requests Long.MAX_VALUE from upstream but respects the backpressure of the downstream. |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public static BackpressureKind | |
| public static BackpressureKind[] |
| ERROR | back to summary |
|---|---|
| public static final BackpressureKind ERROR The operator will emit a MissingBackpressureException if the downstream didn't request enough or in time. | |
| FULL | back to summary |
|---|---|
| public static final BackpressureKind FULL The operator fully supports backpressure and may coordinate downstream requests with upstream requests through batching, arbitration or by other means. | |
| NONE | back to summary |
|---|---|
| public static final BackpressureKind NONE The operator ignores all kinds of backpressure and may overflow the downstream. | |
| PASS_THROUGH | back to summary |
|---|---|
| public static final BackpressureKind PASS_THROUGH The backpressure-related requests pass through this operator without change. | |
| SPECIAL | back to summary |
|---|---|
| public static final BackpressureKind SPECIAL The operator performs special backpressure management; see the associated javadoc. | |
| UNBOUNDED_IN | back to summary |
|---|---|
| public static final BackpressureKind UNBOUNDED_IN The operator requests Long.MAX_VALUE from upstream but respects the backpressure of the downstream. | |
| BackpressureKind | back to summary |
|---|---|
| private BackpressureKind() | |
| valueOf | back to summary |
|---|---|
| public static BackpressureKind valueOf(String name) | |
| values | back to summary |
|---|---|
| public static BackpressureKind[] values() | |