Is there a way to covert Flux to Flow and Mono to coroutine equivalents without blocking.?

# coroutines

[nicholasnet]

Is there a way to covert Flux to Flow and Mono to coroutine equivalents without blocking.?

[Zach Klippenstein (he/him) [MOD]]

https://github.com/Kotlin/kotlinx.coroutines/tree/master/reactive/kotlinx-coroutines-reactor

[nicholasnet]

In that documentation I only see conversion from Flow to Flux not the other way around. Same goes for Mono.

[Marcelo Hernandez]

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().