Package 

Enum Emitter.BackpressureMode

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

    
    public enum Emitter.BackpressureMode
    
                        

    Options to handle backpressure in the emitter.

    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description
      NONE
      ERROR

      Signals a rx.exceptions.MissingBackpressureException if the downstream can't keep up.

      BUFFER

      Buffers (unbounded) all onNext calls until the downstream can consume them.

      DROP

      Drops the incoming onNext value if the downstream can't keep up.

      LATEST

      Keeps the latest onNext value and overwrites it with newer ones until the downstreamcan consume it.