rx-java - RxJava 2.0 で Reactive-Streams プロセッサを使用する

Question

org.reactivestreams.ProcessorRxJava 2.0 で使用したい があります。ただし、org.reactivestreams.Publisherを RxJavaと統合するための変換はありますが(または)io.reactivex.Flowable#fromPublisherを最適に統合する方法は明確ではありません。誰でもこれに光を当てることができますか？org.reactivestreams.Processororg.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);