This might be more of a Spring Webflux question, b...

# coroutines

[Erik Dreyer]

This might be more of a Spring Webflux question, but here goes…
Say I have this controller method

@PostMapping(path = ["/foo"])
  suspend fun example(): Flow<String> {
    val flux: Flux<String> = service.returnsFlux()
    return flux // <-- how to convert to Flow?
  }

(this is a trivial example, but I have an API that returns a FLux<T>)
I’m trying to figure out how to go from a Mono/Flux back to the kotlin coroutines approach for Spring Webflux.

I’d appreciate any help .

[Ivan Pavlov]

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

[Erik Dreyer]

Thanks! In the case of Mono, is it still appropriate to call mono.asFlow() or is there a better way to handle Mono’s?

[Ivan Pavlov]

Not sure, but I think you can use awaitFirst or similar to convert it to a value