asFlux

fun <T : Any> Collectable<T>.asFlux(): Flux<T>(source)

Collectable 转化为 Flux。 需要环境中存在 kotlinx-coroutines-reactor 依赖。