Spring WebFlux handler for kotlin SharedFlow
I can see the following example working in Spring WebFlux handler for a flow builder like the next one:
suspend fun getDummyFlow(req: ServerRequest): ServerResponse {
val flow = flow { // flow builder
for (i in 1..3) {
delay(1000) // pretend we are doing something useful here
emit("Hello $i") // emit next value
}
}
return ServerResponse
.ok()
.contentType(MediaType.TEXT_HTML)
.bodyAndAwait(flow)
}
Yet, I need to...