Class QueueOverflowException

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

public final class QueueOverflowException extends RuntimeException
Indicates an overflow happened because the upstream disregarded backpressure completely or Flow.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:
  • 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