org.reactivestreams.Subscriber#onNext(Object) was called concurrently from multiple threads
without synchronization. Rarely, it is an indication of bugs inside an operator.
| Modifier and Type | Field and Description |
|---|---|
| private static final String | DEFAULT_MESSAGE
The message for queue overflows. |
| private static final long |
| Access | Constructor and Description |
|---|---|
| public | |
| public | QueueOverflowException(String
the error message message)Constructs a QueueOverflowException with the given message but no cause. |
| DEFAULT_MESSAGE | back to summary |
|---|---|
| private static final String DEFAULT_MESSAGE The message for queue overflows.
This can happen if the upstream disregards backpressure completely or calls
| |
| serialVersionUID | back to summary |
|---|---|
| private static final long serialVersionUID | |
| QueueOverflowException | back to summary |
|---|---|
| public QueueOverflowException() Constructs a QueueOverflowException with the default message. | |
| QueueOverflowException | back to summary |
|---|---|
| public QueueOverflowException(String message) Constructs a QueueOverflowException with the given message but no cause.
| |