Is there a way to covert Flux to Flow and Mono to ...
# coroutines
n
Is there a way to covert Flux to Flow and Mono to coroutine equivalents without blocking.?
n
In that documentation I only see conversion from Flow to Flux not the other way around. Same goes for Mono.
m
I'm not familiar with Flux but the library above includes https://github.com/Kotlin/kotlinx.coroutines/tree/master/reactive/kotlinx-coroutines-reactive. And this library provides extensions for any implementation of
Publisher
. It looks like
Flux
implements
Publisher
so you should be able to use
flux.asFlow()
.