Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BACKPRESSURE_ERROR_QUEUE_FULL |
"Queue is full: Reactive Streams source doesn\'t respect backpressure" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ANY |
3 |
public static final int |
ASYNC |
2 |
public static final int |
NONE |
0 |
public static final int |
SYNC |
1 |
public static final int |
THREAD_BARRIER |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
NOT_SUPPORTED_MESSAGE |
"Although QueueSubscription extends Queue it is purely internal and only guarantees support for poll/clear/size/isEmpty. Instances shouldn\'t be used/exposed as Queue outside of Reactor operators." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FALLBACK_PROPERTY |
"reactor.logging.fallback" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CAPACITY_UNSURE |
-2147483648 |