- public Future<AsyncDataChangeEvent<YangInstanceIdentifier, NormalizedNode<?, ?>>> getChangeEvent() {
- return internalListener.receivedChange;
+ public AsyncDataChangeEvent<YangInstanceIdentifier, NormalizedNode<?, ?>> getChangeEvent() throws Exception {
+ return internalListener.receivedChange.get(10, TimeUnit.SECONDS);
+ }
+
+ public void verifyNoChangeEvent() throws Exception {
+ try {
+ Object unexpected = internalListener.receivedChange.get(500, TimeUnit.MILLISECONDS);
+ fail("Got unexpected AsyncDataChangeEvent from the Future: " + unexpected);
+ } catch (TimeoutException e) {
+ // Expected
+ }