Rxjava2.x开发-n-Backpressure-todo

本文主要记录总结背压的相关知识。

当上游发送的事件的速度很快,下游处理事件的速度很慢,就会出现背压,这很好理解,就好比一条水管,上游水流量太大,下游水流量太小,上游送过来的水下游不能及时输出,就会产生压力,这就是背压。

背压是指在异步场景中,被观察者发送事件速度远快于观察者的处理速度的情况下,一种告诉上游的被观察者降低发送速度的策略

本来想写一段程序触发一下 MissingBackpressureException ,结果没成功。

RxJava2.xObservable 是默认不支持背压的,而 Flowable 是支持背压的。

------ 本文结束 🎉🎉 谢谢观看  ------