Class 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 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:
    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.
    • Method Summary

      • Methods inherited from class java.lang.Throwable

        addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Field Detail

      • 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