- Uninterruptibles.sleepUninterruptibly(1, TimeUnit.SECONDS);
- assertEquals(assertMsg, expChangeEventCount, changeList.size());
+ Uninterruptibles.sleepUninterruptibly(500, TimeUnit.MILLISECONDS);
+ synchronized(changeList) {
+ assertEquals(assertMsg, expChangeEventCount, changeList.size());
+ }
+ }
+
+ public void verifyNoNotifiedData(YangInstanceIdentifier... paths) {
+ Set<YangInstanceIdentifier> pathSet = new HashSet<>(Arrays.asList(paths));
+ synchronized(changeList) {
+ for(Collection<DataTreeCandidate> list: changeList) {
+ for(DataTreeCandidate c: list) {
+ assertFalse("Unexpected " + c.getRootPath() + " present in DataTreeCandidate",
+ pathSet.contains(c.getRootPath()));
+ }
+ }
+ }