Понимание реактора FluxProcessor.wrap(вверх по течению, вниз по течению)

Процессоры (субъекты в RxJava) действуют как издатели и подписчики, так что они могут подписаться на издателя и, кроме того, подписаться так, чтобы они передавали значения, полученные от верхнего подписчика:

Publisher
   |
   \/
 Processor
   |
   \/
Subscriber

Как FluxProcessor.wrap() вписаться в эту схему? Например, я хотел бы создать FluxProcessor с FluxProcessor.wrap который получает значения от Flux.range() и может быть подписан на получение значений.

Источник

0 ответов

Другие вопросы по тегам