Measure emission time of a Flux in Reactor?
I would like to measure how long it took to emit all items from Flux:
I have following code:
fun myFancyMethod(request: String): Flux {
return repository.find(request).map {
it.toInt
}
}
I was trying to inspire myself by RouterFunctionMetrics but main difference is that class has access to whole "context" of request.