Fix build failure

2017-09-06 11:42:42 +02:00 · 2017-09-06 11:42:42 +02:00 · 7388b4b768
parent cc8a1fc3b9
commit 7388b4b768
1 changed files with 1 additions and 1 deletions
--- 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
@ -94,7 +94,7 @@ public class CompositeReactiveHealthIndicator implements ReactiveHealthIndicator
 	public Mono<Health> health() {
 		return Flux.fromIterable(this.indicators.entrySet())
 				.flatMap((entry) -> Mono.just(entry.getKey())
-						.and(entry.getValue().health().compose(this.timeoutCompose)))
+						.zipWith(entry.getValue().health().compose(this.timeoutCompose)))
 				.collectMap(Tuple2::getT1, Tuple2::getT2)
 				.map(this.healthAggregator::aggregate);
 	}