在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

回答