X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Ftasks%2FServiceSupervision.java;h=3ab61520baffcb4fe46a9c07a37cafca6f2b7c16;hb=a9bf04b88db3af46dbc0f7251ce079a303ccc9d5;hp=f2de7cf18d1a552020307f106fa6b640556917a8;hpb=cd9e9862fa9a5898f3595b397686861749f72953;p=nonrtric.git

diff --git a/policy-agent/src/main/java/org/oransc/policyagent/tasks/ServiceSupervision.java b/policy-agent/src/main/java/org/oransc/policyagent/tasks/ServiceSupervision.java
index f2de7cf1..3ab61520 100644
--- a/policy-agent/src/main/java/org/oransc/policyagent/tasks/ServiceSupervision.java
+++ b/policy-agent/src/main/java/org/oransc/policyagent/tasks/ServiceSupervision.java
@@ -84,7 +84,7 @@ public class ServiceSupervision {
     private Mono<Policy> deletePolicyInRic(Policy policy) {
         return a1Client.deletePolicy(policy.ric().getConfig().baseUrl(), policy.id()) //
             .onErrorResume(exception -> handleDeleteFromRicFailure(policy, exception)) //
-            .flatMap((nothing) -> Mono.just(policy));
+            .map((nothing) -> policy);
     }
 
     private Mono<Void> handleDeleteFromRicFailure(Policy policy, Throwable e) {