+ public Mono<Integer> notifyProducersJobStarted(EiJob eiJob) {
+ return Flux.fromIterable(eiJob.type().getProducers()) //
+ .flatMap(eiProducer -> notifyProducerJobStarted(eiProducer, eiJob)) //
+ .collectList() //
+ .flatMap(okResponses -> Mono.just(Integer.valueOf(okResponses.size()))); //
+ }
+
+ public Mono<String> notifyProducerJobStarted(EiProducer producer, EiJob eiJob) {