public static final String
BACKPRESSURE_ERROR_QUEUE_FULL
"Queue is full: Reactive Streams source doesn\'t respect backpressure"
public static final int
ANY
3
ASYNC
2
NONE
0
SYNC
1
THREAD_BARRIER
4
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."
FALLBACK_PROPERTY
"reactor.logging.fallback"
CAPACITY_UNSURE
-2147483648