Enum BackpressureStrategy

  • All Implemented Interfaces:
    java.io.Serializable, java.lang.Comparable<BackpressureStrategy>

    public enum BackpressureStrategy
    extends java.lang.Enum<BackpressureStrategy>
    Represents the options for applying backpressure to a source sequence.
    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description
      BUFFER
      Buffers all onNext values until the downstream consumes it.
      DROP
      Drops the most recent onNext value if the downstream can't keep up.
      ERROR
      Signals a MissingBackpressureException in case the downstream can't keep up.
      LATEST
      Keeps only the latest onNext value, overwriting any previous value if the downstream can't keep up.
      MISSING
      The onNext events are written without any buffering or dropping.
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static BackpressureStrategy valueOf​(java.lang.String name)
      Returns the enum constant of this type with the specified name.
      static BackpressureStrategy[] values()
      Returns an array containing the constants of this enum type, in the order they are declared.
      • Methods inherited from class java.lang.Enum

        clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf
      • Methods inherited from class java.lang.Object

        getClass, notify, notifyAll, wait, wait, wait
    • Enum Constant Detail

      • MISSING

        public static final BackpressureStrategy MISSING
        The onNext events are written without any buffering or dropping. Downstream has to deal with any overflow.

        Useful when one applies one of the custom-parameter onBackpressureXXX operators.

      • BUFFER

        public static final BackpressureStrategy BUFFER
        Buffers all onNext values until the downstream consumes it.
      • DROP

        public static final BackpressureStrategy DROP
        Drops the most recent onNext value if the downstream can't keep up.
      • LATEST

        public static final BackpressureStrategy LATEST
        Keeps only the latest onNext value, overwriting any previous value if the downstream can't keep up.
    • Constructor Detail

      • BackpressureStrategy

        private BackpressureStrategy()
    • Method Detail

      • values

        public static BackpressureStrategy[] values()
        Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:
        for (BackpressureStrategy c : BackpressureStrategy.values())
            System.out.println(c);
        
        Returns:
        an array containing the constants of this enum type, in the order they are declared
      • valueOf

        public static BackpressureStrategy valueOf​(java.lang.String name)
        Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)
        Parameters:
        name - the name of the enum constant to be returned.
        Returns:
        the enum constant with the specified name
        Throws:
        java.lang.IllegalArgumentException - if this enum type has no constant with the specified name
        java.lang.NullPointerException - if the argument is null