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