From 1cf7c32a1e5eadca315bc5bedc7a5c0eb37282b3 Mon Sep 17 00:00:00 2001 From: Brian Clozel Date: Wed, 6 Sep 2017 11:52:05 +0200 Subject: [PATCH] Polish --- .../actuate/health/CompositeReactiveHealthIndicator.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/health/CompositeReactiveHealthIndicator.java b/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/health/CompositeReactiveHealthIndicator.java index e6c472af447..cc3cef38707 100644 --- a/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/health/CompositeReactiveHealthIndicator.java +++ b/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/health/CompositeReactiveHealthIndicator.java @@ -93,8 +93,10 @@ public class CompositeReactiveHealthIndicator implements ReactiveHealthIndicator @Override public Mono health() { return Flux.fromIterable(this.indicators.entrySet()) - .flatMap((entry) -> Mono.just(entry.getKey()) - .zipWith(entry.getValue().health().compose(this.timeoutCompose))) + .flatMap((entry) -> Mono.zip( + Mono.just(entry.getKey()), + entry.getValue().health().compose(this.timeoutCompose)) + ) .collectMap(Tuple2::getT1, Tuple2::getT2) .map(this.healthAggregator::aggregate); }