Package io.reactivex.rxjava3.exceptions
Class QueueOverflowException
java.lang.Object
java.lang.Throwable
java.lang.Exception
java.lang.RuntimeException
io.reactivex.rxjava3.exceptions.QueueOverflowException
- All Implemented Interfaces:
Serializable
Indicates an overflow happened because the upstream disregarded backpressure completely or
Subscriber.onNext(Object)
was called concurrently from multiple threads
without synchronization. Rarely, it is an indication of bugs inside an operator.- Since:
- 3.1.6
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final String
The message for queue overflows.private static final long
-
Constructor Summary
ConstructorsConstructorDescriptionConstructs a QueueOverflowException with the default message.QueueOverflowException
(String message) Constructs a QueueOverflowException with the given message but no cause. -
Method Summary
Methods inherited from class java.lang.Throwable
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
DEFAULT_MESSAGE
The message for queue overflows.This can happen if the upstream disregards backpressure completely or calls
Subscriber.onNext(Object)
concurrently from multiple threads without synchronization. Rarely, it is an indication of bugs inside an operator.- See Also:
-
-
Constructor Details
-
QueueOverflowException
public QueueOverflowException()Constructs a QueueOverflowException with the default message. -
QueueOverflowException
Constructs a QueueOverflowException with the given message but no cause.- Parameters:
message
- the error message
-