在RxJava 2.x中使用背压发布主题

我目前正在为当前项目选择RxJava 1.x或2.x。在RxJava 2.x中使用背压发布主题

我基本上需要一个PublishSubject背压战略onBackpressureLatest()。

我想选择RxJava 2.x的，但我不能完全左右得到关于如何背压策略应用到PublishSubject我的头，因为它从FlowableObservable而不是继承。

你能告诉我如何建立与RxJava 2.X一个onBackpressureLatest()背压战略PublishSubject？

在2.x中背压被移至底座式流动的，并且其热伙伴PublishProcessor，ReplayProcessor等

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

2017-02-12 11:16:16 akarnokd

正是我需要的，谢谢！ –

@akarnokd在这种情况下如何调用Flowable的订阅者的onNext（）？我试图做pp.onNext（1），但它没有调用流动用户的onNext（） –

@SandipSoni请打开一个问题，您可以在其中详细说明您拥有什么以及尝试使用哪些源代码。 – akarnokd

回答