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;h=ee7e04fd672afd03baa8dd344050fc510b1eea42;hb=5f38e95cbd87e9c67cd8a8ddb810b629a81cd306;hp=825010ab8c297b6eaec546e593b84e1c6cb7986e;hpb=14accd2e91460d1651fe2c228fe1ba964cbfb6a6;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..ee7e04fd 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 @@ -36,6 +36,7 @@ import reactor.test.StepVerifier; @ExtendWith(MockitoExtension.class) public class LockTest { + @SuppressWarnings("squid:S2925") // "Thread.sleep" should not be used in tests. private void sleep() { try { Thread.sleep(100); @@ -71,10 +72,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) //