X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Ftasks%2FRicSupervision.java;h=228038afa10bac5f849ecfae35e250ba7ebc88d7;hb=eb4ea800b974ca57fd4ad534171520f27032abf6;hp=77be8b316b5c365ce2b3cbcf811383fab5949d08;hpb=182492b41c32c67d53906cb12d66dbc2dcf5159b;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSupervision.java b/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSupervision.java index 77be8b31..228038af 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSupervision.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSupervision.java @@ -67,6 +67,20 @@ public class RicSupervision { } } + private static class RicData { + RicData(Ric ric, A1Client a1Client) { + this.ric = ric; + this.a1Client = a1Client; + } + + A1Client getClient() { + return a1Client; + } + + final Ric ric; + private final A1Client a1Client; + } + @Autowired public RicSupervision(Rics rics, Policies policies, A1ClientFactory a1ClientFactory, PolicyTypes policyTypes, Services services) { @@ -90,7 +104,6 @@ public class RicSupervision { return Flux.fromIterable(rics.getRics()) // .flatMap(this::createRicData) // .flatMap(this::checkOneRic); - } private Mono checkOneRic(RicData ricData) { @@ -133,20 +146,6 @@ public class RicSupervision { } } - private static class RicData { - RicData(Ric ric, A1Client a1Client) { - this.ric = ric; - this.a1Client = a1Client; - } - - A1Client getClient() { - return a1Client; - } - - final Ric ric; - private final A1Client a1Client; - } - private Mono createRicData(Ric ric) { return Mono.just(ric) // .flatMap(aRic -> this.a1ClientFactory.createA1Client(ric)) // @@ -185,7 +184,6 @@ public class RicSupervision { } private Mono checkRicPolicyTypes(RicData ric) { - return ric.getClient().getPolicyTypeIdentities() // .flatMap(ricTypes -> validateTypes(ricTypes, ric)); }