start method

void start()

Starts listening for notifications of the requests and responses in the $domainNameSpace.$rpcsNameSpace.$baseNameSpace namespace

Implementation

void start() {
  logger.info('allowList is $allowList');
  var regex = 'request.\\d+.$domainNameSpace.$rpcsNameSpace.$baseNameSpace@';
  logger.info('Subscribing to $regex');

  _requestStream = atClient.notificationService
      .subscribe(regex: regex, shouldDecrypt: true);

  _requestStream!.listen(handleRequestNotification,
      onError: (e) => logger.severe('Notification Failed: $e'),
      onDone: () => logger.info('RPC request listener stopped'));

  regex =
      '(success|error|ack|nack).\\d+.$domainNameSpace.$rpcsNameSpace.$baseNameSpace@';
  logger.info('Subscribing to $regex');

  _responseStream = atClient.notificationService
      .subscribe(regex: regex, shouldDecrypt: true);

  _responseStream!.listen(handleResponseNotification,
      onError: (e) => logger.severe('Notification Failed: $e'),
      onDone: () => logger.info('RPC response listener stopped'));
}