start method

Implementation

void start() {
  // Trigger immediately
  dbLogger.info('>>>> Trigger immediately');
  flushStoredEvents().catchError((e, st) {
    dbLogger.severe('Error occurred when scheduler trying to send events', e, st);
  });

  dbLogger.info('>>>> START Scheduler');
  _timer?.cancel();
  _timer = Timer.periodic(
    Duration(milliseconds: flushInterval),
        (_) async {
          dbLogger.info('>>>> Interval flush triggered');
      try {
        await flushStoredEvents();
      } catch (e, st) {
        dbLogger.severe('Error occurred when scheduler trying to send events', e, st);
      }
    },
  );
}