+ private Flux<Object> startRecover(Ric ric, A1Client a1Client) {
+ Flux<PolicyType> recoverTypes = recoverPolicyTypes(ric, a1Client);
+ Flux<?> deletePoliciesInRic = deleteAllPoliciesInRic(ric, a1Client);
+ Flux<?> recreatePoliciesInRic = recreateAllPoliciesInRic(ric, a1Client);
+
+ return Flux.concat(recoverTypes, deletePoliciesInRic, recreatePoliciesInRic);
+ }
+