File tree Expand file tree Collapse file tree 1 file changed +22
-0
lines changed
src/main/java/rx/exceptions Expand file tree Collapse file tree 1 file changed +22
-0
lines changed Original file line number Diff line number Diff line change 15
15
*/
16
16
package rx .exceptions ;
17
17
18
+ /**
19
+ * {@code MissingBackpressureException} indicates that a Subscriber or operator attempted to apply reactive pull
20
+ * backpressure to an Observable that does not implement it.
21
+ * <p>
22
+ * If an Observable has not been written to support reactive pull backpressure (such support is not a
23
+ * requirement for Observables), you can apply one of the following operators to it, each of which forces a
24
+ * simple form of backpressure behavior:
25
+ * <dl>
26
+ * <dt><code>onBackpressureBuffer</code></dt>
27
+ * <dd>maintains a buffer of all emissions from the source Observable and emits them to downstream Subscribers
28
+ * according to the requests they generate</dd>
29
+ * <dt><code>onBackpressureDrop</code></dt>
30
+ * <dd>drops emissions from the source Observable unless there is a pending request from a downstream
31
+ * Subscriber, in which case it will emit enough items to fulfill the request</dd>
32
+ * </dl>
33
+ * If you do not apply either of these operators to an Observable that does not support backpressure, and if
34
+ * either you as the Subscriber or some operator between you and the Observable attempts to apply reactive pull
35
+ * backpressure, you will encounter a {@code MissingBackpressureException} which you will be notified of via
36
+ * your {@code onError} callback.
37
+ *
38
+ * @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
39
+ */
18
40
public class MissingBackpressureException extends Exception {
19
41
20
42
private static final long serialVersionUID = 7250870679677032194L ;
You can’t perform that action at this time.
0 commit comments