+ }
+
+ private Flux<RicData> createTask() {
+ synchronized (this.rics) {
+ return Flux.fromIterable(rics.getRics()) //
+ .flatMap(ric -> createRicData(ric)) //
+ .flatMap(ricData -> checkRicState(ricData)) //
+ .flatMap(ricData -> checkRicPolicies(ricData)) //
+ .flatMap(ricData -> checkRicPolicyTypes(ricData));
+ }
+ }
+
+ private static class RicData {
+ RicData(Ric ric, A1Client a1Client) {
+ this.ric = ric;
+ this.a1Client = a1Client;
+ }