|
|
@ -78,8 +78,9 @@ public class CompositeReactiveHealthIndicator implements ReactiveHealthIndicator
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public Mono<Health> health() {
|
|
|
|
public Mono<Health> health() {
|
|
|
|
return Flux.fromIterable(this.registry.getAll().entrySet()).flatMap(
|
|
|
|
return Flux.fromIterable(this.registry.getAll().entrySet())
|
|
|
|
(entry) -> Mono.zip(Mono.just(entry.getKey()), entry.getValue().health().compose(this.timeoutCompose)))
|
|
|
|
.flatMap((entry) -> Mono.zip(Mono.just(entry.getKey()),
|
|
|
|
|
|
|
|
entry.getValue().health().transformDeferred(this.timeoutCompose)))
|
|
|
|
.collectMap(Tuple2::getT1, Tuple2::getT2).map(this.healthAggregator::aggregate);
|
|
|
|
.collectMap(Tuple2::getT1, Tuple2::getT2).map(this.healthAggregator::aggregate);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|