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; allowAll is $allowAll');
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'));
}