RxJava 2.0でReactive-Streamsプロセッサを使用

Question

RxJava 2.0で使用したいorg.reactivestreams.Processorがあります。しかし、org.reactivestreams.Publisherをio.reactivex.Flowable#fromPublisherのようにRxJavaに統合するための変換はありますが、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);