我目前正在为我当前的项目选择 RxJava 1.x 或 2.x。
我基本上需要一个PublishSubject采用背压策略onBackpressureLatest().
我想选择 RxJava 2.x，但我不太清楚如何将反压策略应用于PublishSubject，因为它继承自Observable而不是来自Flowable.
你能告诉我如何创建一个PublishSubject with a onBackpressureLatest()RxJava 2.x 中的反压策略？
在 2.x 中，背压被移至基本类型 Flowable 及其热门合作伙伴 PublishProcessor、ReplayProcessor 等。
PublishProcessor<Integer> pp = PublishProcessor.create();
Flowable<Integer> out = pp.onBackpressureLatest();
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
