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:
java.io.Serializable
public final class QueueOverflowException extends java.lang.RuntimeException
Indicates an overflow happened because the upstream disregarded backpressure completely orSubscriber.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:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description private static java.lang.String
DEFAULT_MESSAGE
The message for queue overflows.private static long
serialVersionUID
-
Constructor Summary
Constructors Constructor Description QueueOverflowException()
Constructs a QueueOverflowException with the default message.QueueOverflowException(java.lang.String message)
Constructs a QueueOverflowException with the given message but no cause.
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
DEFAULT_MESSAGE
private static final java.lang.String 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:
- Constant Field Values
-
-
Constructor Detail
-
QueueOverflowException
public QueueOverflowException()
Constructs a QueueOverflowException with the default message.
-
QueueOverflowException
public QueueOverflowException(java.lang.String message)
Constructs a QueueOverflowException with the given message but no cause.- Parameters:
message
- the error message
-
-