start method

void start()

Start the read loop (idempotent).

Implementation

void start() {
  if (_started) return;
  _started = true;
  _subscription = _transport.onMessage.listen(
    _onBytes,
    onError: (_) => _failAll(),
    onDone: () => _failAll(),
  );
}