Future addStream()

in lib/src/copy/web_socket_impl.dart [648:663]

• 16 lines of code
• 3 McCabe index (conditional complexity)

  Future addStream(var stream) {
    if (_closed) {
      stream.listen(null).cancel();
      return Future.value(webSocket);
    }
    _ensureController();
    _completer = Completer();
    _subscription = stream.listen((data) {
      _controller!.add(data);
    }, onDone: _done, onError: _done, cancelOnError: true);
    if (_issuedPause) {
      _subscription!.pause();
      _issuedPause = false;
    }
    return _completer!.future;
  }