- public Mono<String> deletePolicy(String policyId) {
- logger.debug("deletePolicy nearRtRicUrl = {}, policyId = {}", ricConfig.baseUrl(), policyId);
- return restClient.delete("/policies/" + policyId);
+ public Mono<String> deletePolicy(Policy policy) {
+ return deletePolicy(policy.id());
+ }
+
+ @Override
+ public Flux<String> deleteAllPolicies() {
+ return getPolicyIdentities() //
+ .flatMapMany(policyIds -> Flux.fromIterable(policyIds)) // )
+ .flatMap(policyId -> deletePolicy(policyId)); //