Использование процессора реактивных потоков с RxJava 2.0

Question

У меня есть org.reactivestreams.Processor, который я бы хотел использовать с RxJava 2.0. Однако, хотя есть преобразования для интеграции org.reactivestreams.Publisher с RxJava, например io.reactivex.Flowable#fromPublisher, мне не ясно, как лучше всего интегрировать org.reactivestreams.Processor (или org.reactivestreams.Subscriber). Может ли кто-нибудь осветить этот свет?

Answer 1

Вы обернуть Publisher стороны и держать Subscriber сторону как:

Processor proc = ... 

Subscriber sub = proc; 
Flowable flow = Flowable.fromPublisher(proc); 

flow.map(v -> v.toString()).subscribe(System.out::println); 

sub.onNext(1);