start method

Implementation

@override
Future<void> start() async {
  await initialize();
  if (subscription != null) {
    return;
  }
  String dbId = myConfig!.serverConfig.dbConnInfo.appId;
  String ch = 'databases.$dbId.collections.hycop_delta.documents';
  subscription = Realtime(AbsDatabase.awDBConn!).subscribe([ch]);
  realtimeListener = subscription!.stream.listen((event) {
    processEvent(event.payload);
  });
}