Class QueueOverflowException

java.lang.Object
java.lang.Throwable
java.lang.Exception
java.lang.RuntimeException
io.reactivex.rxjava3.exceptions.QueueOverflowException
All Implemented Interfaces:
Serializable

public final class QueueOverflowException extends RuntimeException
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 Details

    • serialVersionUID

      private static final long serialVersionUID
      See Also:
    • DEFAULT_MESSAGE

      private static final 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:
  • Constructor Details

    • QueueOverflowException

      public QueueOverflowException()
      Constructs a QueueOverflowException with the default message.
    • QueueOverflowException

      public QueueOverflowException(String message)
      Constructs a QueueOverflowException with the given message but no cause.
      Parameters:
      message - the error message