PublishSubject mit Gegendruck in RxJava 2.x

Question

Ich wähle derzeit zwischen RxJava 1.x oder 2.x für mein aktuelles Projekt.

Ich brauche grundsätzlich eine PublishSubject mit einer Gegendruckstrategie onBackpressureLatest().

Ich mag RxJava 2.x wählen, aber ich kann nicht ganz meinen Kopf herum auf, wie eine Rückstau Strategie auf ein PublishSubject anzuwenden, wie es von Observable und nicht von Flowable erbt.

---

Könnten Sie mir bitte sagen, wie ein PublishSubject mit einer onBackpressureLatest() Rückstau Strategie in RxJava 2.x zu schaffen?

Answer 1

In 2.x wurde der Gegendruck in den Basistyp fließfähig und seine heißen Partner bewegt PublishProcessor, ReplayProcessor usw.

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