- Flux<PolicyType> recoverTypes = synchronizePolicyTypes(ric, a1Client);
- Collection<Policy> policiesForRic = policies.getForRic(ric.name());
- Flux<?> policiesDeletedInRic = Flux.empty();
- Flux<?> policiesRecreatedInRic = Flux.empty();
- if (!policiesForRic.isEmpty()) {
- policiesDeletedInRic = a1Client.deleteAllPolicies();
- policiesRecreatedInRic = recreateAllPoliciesInRic(ric, a1Client);
- }
- return Flux.concat(recoverTypes, policiesDeletedInRic, policiesRecreatedInRic);
+ Flux<PolicyType> synchronizedTypes = synchronizePolicyTypes(ric, a1Client);
+ Flux<?> policiesDeletedInRic = a1Client.deleteAllPolicies();
+ Flux<Policy> policiesRecreatedInRic = recreateAllPoliciesInRic(ric, a1Client);
+
+ return Flux.concat(synchronizedTypes, policiesDeletedInRic, policiesRecreatedInRic);