+ @Override
+ public void onInitialData() {
+ onInitialDataEventCount.incrementAndGet();
+ onInitialDataLatch.countDown();
+ }
+
+ public void verifyOnInitialDataEvent() {
+ assertTrue("onInitialData was not triggered",
+ Uninterruptibles.awaitUninterruptibly(onInitialDataLatch, 5, TimeUnit.SECONDS));
+ assertEquals("onInitialDataEventCount", 1, onInitialDataEventCount.get());
+ }
+
+ public void verifyNoOnInitialDataEvent() {
+ assertFalse("onInitialData was triggered unexpectedly",
+ Uninterruptibles.awaitUninterruptibly(onInitialDataLatch, 500, TimeUnit.MILLISECONDS));
+ }
+