- private Flux<String> deleteAllPoliciesInRic(Ric ric) {
- return a1Client.getPolicyIdentities(ric.getConfig().baseUrl()) //
- .flatMapMany(policyIds -> Flux.fromIterable(policyIds)) //
- .doOnNext(policyId -> logger.debug("Deleting policy: {}, for ric: {}", policyId, ric.getConfig().name()))
- .flatMap(policyId -> a1Client.deletePolicy(ric.getConfig().baseUrl(), policyId)); //
- }
-
- private Flux<String> recreateAllPoliciesInRic(Ric ric) {