Confused about Multi.asFlow extension

[hantsy]

Kotlinx coroutines Reactive includes an general extension fun to convert Publisher to Kotlin Flow, https://github.com/Kotlin/kotlinx.coroutines/blob/master/reactive/kotlinx-coroutines-reactive/src/ReactiveFlow.kt

Besides add extensions to general ReactiveStreams API, https://github.com/Kotlin/kotlinx.coroutines/tree/master/reactive it also supports Reactor, Rxjava2/3, JDK 9 Flow API.

But in these implementations, it does requires a suspend modifier for fun .asFlow.

[jponge]

/cc @heubeck

[heubeck]

Thank you for pointing this out, @hantsy.
Mutiny-Kotlin was created before Mutiny switched to the Publisher API.

Will have a look and probably propose a refactoring.

[hantsy]

The JDK9 extension also includes a asFlow fun, I have tried here
https://github.com/hantsy/quarkus-sandbox/blob/master/mongodb-kotlin-co/src/main/kotlin/com/example/PostResources.kt#L4
and
https://github.com/hantsy/quarkus-sandbox/blob/master/mongodb-kotlin-co/src/main/kotlin/com/example/PostResources.kt#L28
it works.

[heubeck]

lets follow up on this discussion in #1325