是否可以从Reactor Flux或RxJava2 Observable / Flowable到AkkaStreams源使用适配器？

Question

[有时候，有一些库，例如R2DBC，它返回一个Reactive Stream，即Reactor Flux，但是在Http层中，我们需要另一个Reactive Stream，即AkkaStreams Source，AkkaHttp知道并创建了一个HTTP客户端有用的流场景不断的内存处理。

在反应流实现之间进行转换的方式是什么？有可用的适配器库吗？

Answer 1

是，两个库（Reactor和AkkaStreams）都可以在它们的类型（Source，Flowable / Observable）和Java 9中提供的可互操作性的Publisher类型之间进行转换。例如Source.fromPublisher(r2dbc.query().asPublisher()或类似的东西。