在RxJava 2.x中发布具有背压的主题

Question

我目前正在为我当前的项目选择RxJava 1.x或2.x.

我基本上需要PublishSubject一个背压策略onBackpressureLatest().

我想选择RxJava 2.x,但我不能完全理解如何将背压策略应用于a PublishSubject,因为它继承自Observable而不是继承Flowable.

---

你能告诉我如何在RxJava 2.x中创建一个PublishSubject带onBackpressureLatest()背压策略吗？

Answer 1

在2.x中,背压被移动到基本类型Flowable及其热门合作伙伴PublishProcessor,ReplayProcessor等.

PublishProcessor<Integer> pp = PublishProcessor.create();
Flowable<Integer> out = pp.onBackpressureLatest();

Answer 2

我在某个时候使用过这样的东西：

Subject<Object> emitterSubject = PublishSubject.<Object>create().toSerialized();

emitterSubject.toFlowable(BackpressureStrategy.LATEST)