在 RxJava 中带有背压的 PublishSubject 2.x
PublishSubject with backpressure in RxJava 2.x
我目前正在为我当前的项目选择 RxJava 1.x 或 2.x。
我基本上需要一个带有背压策略的 PublishSubject
onBackpressureLatest()
。
我想选择 RxJava 2.x,但我不太清楚如何将背压策略应用于 PublishSubject
,因为它继承自 Observable
而不是来自 Flowable
.
你能告诉我如何在 RxJava 2.x 中使用 onBackpressureLatest()
背压策略创建 PublishSubject
吗?
在 2.x 中,背压被移至基本类型 Flowable 及其热门伙伴 PublishProcessor、ReplayProcessor 等
PublishProcessor<Integer> pp = PublishProcessor.create();
Flowable<Integer> out = pp.onBackpressureLatest();
我在某些时候使用了这样的东西:
Subject<Object> emitterSubject = PublishSubject.<Object>create().toSerialized();
emitterSubject.toFlowable(BackpressureStrategy.LATEST)
我目前正在为我当前的项目选择 RxJava 1.x 或 2.x。
我基本上需要一个带有背压策略的 PublishSubject
onBackpressureLatest()
。
我想选择 RxJava 2.x,但我不太清楚如何将背压策略应用于 PublishSubject
,因为它继承自 Observable
而不是来自 Flowable
.
你能告诉我如何在 RxJava 2.x 中使用 onBackpressureLatest()
背压策略创建 PublishSubject
吗?
在 2.x 中,背压被移至基本类型 Flowable 及其热门伙伴 PublishProcessor、ReplayProcessor 等
PublishProcessor<Integer> pp = PublishProcessor.create();
Flowable<Integer> out = pp.onBackpressureLatest();
我在某些时候使用了这样的东西:
Subject<Object> emitterSubject = PublishSubject.<Object>create().toSerialized();
emitterSubject.toFlowable(BackpressureStrategy.LATEST)