TelemetrySubscriber constructor

TelemetrySubscriber(
  1. TelemetryService telemetryService,
  2. List<WebsocketCmd> subscriptionCommands
)

Implementation

TelemetrySubscriber(TelemetryService telemetryService,
    List<WebsocketCmd> subscriptionCommands)
    : _telemetryService = telemetryService,
      _subscriptionCommands = subscriptionCommands,
      _dataStreamController = StreamController.broadcast(),
      _entityDataStreamController = StreamController.broadcast(),
      _alarmDataStreamController = StreamController.broadcast(),
      _entityCountStreamController = StreamController.broadcast(),
      _notificationCountStreamController = StreamController.broadcast(),
      _notificationUpdateStreamController = StreamController.broadcast(),
      _reconnectStreamController = StreamController.broadcast();