start method

void start()

Implementation

void start() {
  if (_isStarted) return;
  _isStarted = true;

  _reader.start();
  _reader.stream.listen(
    _handleData,
    onError: (err) {
      _eventController.addError(err);
    },
    onDone: () {
      _flush(expired: true);
      _eventController.close();
    },
  );
}