Как работает противодавление для горячей текучести с несколькими подписчиками - PullRequest
0 голосов
/ 30 июня 2018

Если бы у нас был горячий Flowable (например, PublishProcessor) со стратегией противодавления. Как это работает, когда есть несколько подписчиков, и только у одного из них есть проблемы с обработкой полученных элементов?

Подписчики, которые могут посещать сообщения в это время, подвержены влиянию стратегии противодавления, которая необходима более медленной?

EDIT : После прочтения предложенной документации @akarnokd и просмотра диаграммы я увидел, что для PublishProcessor.

нет управления обратным давлением.

Но что, если я зацеплю .onBackPressureXXXX(). Насколько я понимаю, похоже, что стратегия будет применяться к каждому подписчику, но я просто хочу быть уверен, что получит подтверждение от опытного разработчика.

...