subscribe method
Implementation
@override
void subscribe(TelemetrySubscriber subscriber) {
_isActive = true;
subscriber.subscriptionCommands.forEach((subscriptionCommand) {
var cmdId = _nextCmdId();
if (!(subscriptionCommand is MarkAsReadCmd) &&
!(subscriptionCommand is MarkAllAsReadCmd)) {
_subscribersMap[cmdId] = subscriber;
}
subscriptionCommand.cmdId = cmdId;
_cmdsWrapper.cmds.add(subscriptionCommand);
});
_subscribersCount++;
_publishCommands();
}