anchor.diff:          _nextResponseCompleter = new Completer();
           // Listen for response.
           _nextResponseCompleter.future
  -            .whenComplete(() {
  -               _nextResponseCompleter = null;
  -             })
               .then((incoming) {
                 incoming.dataDone.then((_) {
                   if (incoming.headers.persistentConnection &&
                       request.persistentConnection) {
  -                  _subscription.resume();
                     // Return connection, now we are done.
                     _httpClient._returnConnection(this);
  +                  _subscription.resume();
                   } else {
                     destroy();
                   }
  
positive.code:               destroy();
                request._onError(error);
              });
  
          return _socket.addStream(stream)
              .catchError((e) {
  
negative.code:   }
  
    _HttpClientRequest send(Uri uri, int port, String method, bool isDirect) {
      // Start with pausing the parser.
      _subscription.pause();
      var outgoing = new _HttpOutgoing();
      // Create new request object, wrapping the outgoing connection.
      var request = new _HttpClientRequest(outgoing,
  