Future listen()

in lib/src/client.dart [82:91]

• 10 lines of code
• 2 McCabe index (conditional complexity)

  Future listen() {
    _channel.stream.listen(_handleResponse, onError: (error, stackTrace) {
      _done.completeError(error, stackTrace);
      _channel.sink.close();
    }, onDone: () {
      if (!_done.isCompleted) _done.complete();
      close();
    });
    return done;
  }