ReactiveDatasource { public boolean isStarted() { return pollerDaemon != null; } ReactiveDatasource(EventSource eventSource); @VisibleForTesting  ReactiveDatasource(EventSource eventSource, EventChannel<T> eventChannel); @VisibleForTesting  ReactiveDatasource(EventChannel<T> eventChannel, EventPoller<T> eventPoller); void addEventListener(EventListener<T> listener); boolean isStarted(); void start(); void stop();  }
@Test(groups = SMALL) public void testReactiveSourceIsNotStartedWhenInstantiated() { assertFalse(reactiveDatasource.isStarted()); }