flux

得到一个将 Flow 的结果转化为 Flux 的响应式转化器。需要你的依赖环境中存在 kotlinx-coroutines-reactor 依赖。

以 Collectable 的场景下为例:

Flux<String> flux = Collectables.transform(foo.collectable, flux());