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 .

Thanks! In the case of

Mono

, is it still appropriate to call

mono.asFlow()

or is there a better way to handle Mono’s?

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