Есть ли адаптер от Reactor Flux или RxJava2 Observable / Flowable для источника AkkaStreams?

Question

Иногда существуют библиотеки, такие как R2DB C, которые возвращают Reactive Stream, а именно Reactor Flux, но затем на уровне Http нам нужен другой Reactive Stream, а именно AkkaStreams Source, который знает AkkaHttp и создает сценарий потоковой передачи с http-клиент полезен для постоянной обработки памяти.

Какой способ преобразования между реализациями реактивного потока? Доступны ли библиотеки адаптеров?

Answer 1

Да, обе библиотеки (Reactor & AkkaStreams) имеют возможность преобразования между их типами (Source, Flowable / Observable) и типом Publisher, существующим в Java 9, что обеспечивает совместимость. Например, Source.fromPublisher(r2dbc.query().asPublisher() или что-то на этот счет.