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

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

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


reactor project-reactor rx-java akka akka-stream
person NicuMarasoiu    schedule 10.02.2020    source источник
comment
Я уже размещал ссылки на официальную библиотеку AkkaStreams, в которой есть специальный раздел о взаимодействии: doc.akka.io/docs/akka/current/stream/. Почему вы все время просите библиотеки / документацию?   -  person akarnokd    schedule 10.02.2020

Ответы (1)


arrow_upward
1
arrow_downward

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

person NicuMarasoiu    schedule 13.02.2020