class AggregatingValidator implements AdmissionValidator<JobDescriptor> {

    @Override
    public Mono<Set<ValidationError>> validate(JobDescriptor jobDescriptor) {
        return Mono.zip(
                getMonos(jobDescriptor, timeout, validators),
                objects -> Arrays.stream(objects)
                        .map(objectSet -> (Set<ValidationError>) objectSet)
                        .flatMap(Set::stream)
                        .collect(Collectors.toSet()))
                .defaultIfEmpty(Collections.emptySet());
    }

    @Inject public  AggregatingValidator(
            TitusValidatorConfiguration configuration,
            Registry registry,
            Collection<? extends AdmissionValidator<JobDescriptor>> validators);

}