X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Ftest%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Frepository%2FLockTest.java;fp=policy-agent%2Fsrc%2Ftest%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Frepository%2FLockTest.java;h=6fd6c8b95cf479ac39d1cc91fdf549c47aeb79e3;hb=c5c251953f36a3a56613ad28f2d73f958ff58295;hp=825010ab8c297b6eaec546e593b84e1c6cb7986e;hpb=5606c08e8a5cc813a6a6eb09bacce123137e43e2;p=nonrtric.git diff --git a/policy-agent/src/test/java/org/oransc/policyagent/repository/LockTest.java b/policy-agent/src/test/java/org/oransc/policyagent/repository/LockTest.java index 825010ab..6fd6c8b9 100644 --- a/policy-agent/src/test/java/org/oransc/policyagent/repository/LockTest.java +++ b/policy-agent/src/test/java/org/oransc/policyagent/repository/LockTest.java @@ -71,10 +71,8 @@ public class LockTest { Lock lock = new Lock(); Mono seq = lock.lock(LockType.EXCLUSIVE) // - .doOnNext(l -> System.out.println("1 " + l)) // .flatMap(l -> lock.lock(LockType.EXCLUSIVE)) // - .flatMap(l -> lock.unlock()) // - .doOnNext(l -> System.out.println("2 " + l)); // + .flatMap(l -> lock.unlock()); asynchUnlock(lock); StepVerifier.create(seq) //