File tree Expand file tree Collapse file tree 1 file changed +9
-2
lines changed
src/main/java/rx/exceptions Expand file tree Collapse file tree 1 file changed +9
-2
lines changed Original file line number Diff line number Diff line change 3434 * either you as the Subscriber or some operator between you and the Observable attempts to apply reactive pull
3535 * backpressure, you will encounter a {@code MissingBackpressureException} which you will be notified of via
3636 * your {@code onError} callback.
37- *
38- * @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
37+ * <p>
38+ * There are, however, other options. You can throttle an over-producing Observable with operators like
39+ * {@code sample}/{@code throttleLast}, {@code throttleFirst}, or {@code throttleWithTimeout}/{@code debounce}.
40+ * You can also take the large number of items emitted by an over-producing Observable and package them into
41+ * a smaller set of emissions by using operators like {@code buffer} and {@code window}.
42+ * <p>
43+ * For a more complete discussion of the options available to you for dealing with issues related to
44+ * backpressure and flow control in RxJava, see
45+ * <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>.
3946 */
4047public class MissingBackpressureException extends Exception {
4148
You can’t perform that action at this time.
0 commit comments