public class MissingBackpressureException
If an Observable has not been written to support reactive pull backpressure (such support is not a requirement for Observables), you can apply one of the following operators to it, each of which forces a simple form of backpressure behavior:
MissingBackpressureException which you will be notified of via
There are, however, other options. You can throttle an over-producing Observable with operators like
You can also take the large number of items emitted by an over-producing Observable and package them into
a smaller set of emissions by using operators like
For a more complete discussion of the options available to you for dealing with issues related to backpressure and flow control in RxJava, see RxJava wiki: Backpressure.
|Constructor and Description
Constructs the exception without any custom message.
Constructs the exception with the given customized message.
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
public MissingBackpressureException(java.lang.String message)
message - the customized message