class ReactiveDatasource {

    public boolean isStarted() {
        return pollerDaemon != null;
    }

    public  ReactiveDatasource(EventSource eventSource);
    @VisibleForTesting  ReactiveDatasource(EventSource eventSource, EventChannel<T> eventChannel);
    @VisibleForTesting  ReactiveDatasource(EventChannel<T> eventChannel, EventPoller<T> eventPoller);

}