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
invalid reference
org.reactivestreams.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