start method

@override Future<void> start()

Implementation

@override
Future<void> start() async {
  realTimeKey = null;
  await initialize();
  logger.finest('SupabaseRealtime start()');
  if (_isListenComplete) {
    _isListenComplete = false;
    logger.finest('listener restart $lastUpdateTimeStr');
    _deltaChannel = Supabase.instance.client
        .channel('public:hycop_delta')
        .onPostgresChanges(
            event: PostgresChangeEvent.insert,
            schema: 'public',
            table: 'hycop_delta',
            //filter: ,
            callback: (PostgresChangePayload payload) {
              logger.finest('insert received: ${payload.toString()}');
              processEvent(payload.newRecord);
            })
        .onPostgresChanges(
            event: PostgresChangeEvent.update,
            schema: 'public',
            table: 'hycop_delta',
            //filter: ,
            callback: (PostgresChangePayload payload) {
              logger.finest('update received: ${payload.toString()}');
              processEvent(payload.newRecord);
            })
        .subscribe();
  }
  //});
}