class AggregatingContainerHealthService implements ContainerHealthService {

    @Override
    public Flux<ContainerHealthEvent> events(boolean snapshot) {
        return snapshot
                ? healthStatuses.compose(ReactorExt.head(() -> Collections.singletonList(buildCurrentSnapshot())))
                : healthStatuses;
    }

    @Inject public  AggregatingContainerHealthService(Set<ContainerHealthService> healthServices,
                                             ReadOnlyJobOperations jobOperations,
                                             TitusRuntime titusRuntime);

}