Как рассчитать общее время, затраченное на процесс в Java, реактивный ⇐ JAVA

[Anonymous]

У меня есть приложение реактивной весенней загрузки Java, в котором я выполняю приведенную ниже логику. Я хочу записать, сколько времени требуется для завершения всего этого метода. Я могу изменить сигнатуру метода, но хотелось бы оставить ее как есть.

Код: Выделить всё

public Flux verifyStuff(){
return client.getSomeData1(query)
.doOnNext(
result1 -> log.info("Retrieved '{}' ", result1.size()))
.flatMapMany(result1 -> Flux.fromStream(result1.stream())
.concatMap(this::verifyresult1()));
}

Таким образом, метод на самом деле реактивно получает список результатов и последовательно вызывает другую службу.
Я пробовал использовать elapsed(), но у меня не закружилась голова о том, как это работает.
Также попробовал версию ниже.

Код: Выделить всё

public Flux verifyStuff(){
StopWatch stopWatch = new StopWatch();
stopWatch.start();
return client.getSomeData1(query)
.doOnNext(
result1 -> log.info("Retrieved '{}' ", result1.size()))
.flatMapMany(result1 -> Flux.fromStream(result1.stream())
.concatMap(this::verifyresult1())
.doFinally(signalType -> {
stopWatch.stop();
log.info("To execution time for verifying marketplace partners is {}ms",
stopWatch.getTotalTimeMillis());
});;
}

Но это завершает журнал до того, как все потоки будут решены в «verifyresult1»

Подробнее здесь: https://stackoverflow.com/questions/793 ... a-reactive