PublishSubject с противодавлением в RxJava 2.x

Question

В настоящее время я выбираю между RxJava 1.x или 2.x для моего текущего проекта.

Мне в основном нужен PublishSubject с стратегией противодавления onBackpressureLatest().

Я хочу выбрать RxJava 2.x, но я совсем не могу получить мою голову вокруг о том, как применить стратегию противодавления к PublishSubject, так как он наследует от Observable и не от Flowable.

---

Не могли бы вы сказать мне, как создать PublishSubject с стратегией onBackpressureLatest() противодавления в RxJava 2.x?

Answer 1

В 2.x противодавление был перемещен в базовый тип текучий и его горячих партнеров PublishProcessor, ReplayProcessor и т.д.

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