subscribe method

  1. @override
void subscribe(
  1. TelemetrySubscriber subscriber
)
override

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();
}