start method

@override Future<void> start()

Implementation

@override
Future<void> start() async {
  await _channelSession.ready;
  Future(() => _shareConnectionState(ConnectionState.online));
  log("Connected", name: "ZapSubscriber");
  _subscription = _connectionStream.listen(
      (data) {
        final eventData = Validators.convertAndValidate(data);
        _streamController.add(eventData);
      },
      cancelOnError: true,
      onDone: () {
        _shareConnectionState(ConnectionState.offline);
        log("Connected", name: "ZapSubscriber");
        _subscription?.cancel();
      });
}