Ich möchte die gesamte verstrichene Zeit einer gesamten Pipeline-Ausführung protokollieren.
Ich habe eine Methode elapsed() gefunden, aber ich möchte die Gesamtzeit, aber ich möchte die Gesamtzeit, nicht für Elemente (doOnNext).
Ich habe viele Optionen gesehen, bin mir aber nicht sicher, welche das richtige zu verwenden.
Mein Code:
private Mono getData(String slug) {
Code: Select all
var stopWatch = StopWatch.createStarted();
return getProducts(
Mono.zip(
proxy.getExternalData(slug),
getProductPersonalization(slug)))
.doOnSuccess(it -> log.info("Finish with success:"))
.doOnTerminate(() -> {
stopWatch.stop();
log.info("getData execution time: {} ms",
stopWatch.getTime(TimeUnit.MILLISECONDS));
});
Code: Select all
private Mono getProducts(Mono tuple);
Mobile version