anchor.diff:        _state = _State.FAILURE;
         // Report the error through the error callback if any. Otherwise
         // throw the error.
  -      error(new HttpException(
  +      _reportError(new HttpException(
                     "Connection closed before full body was received"));
       }
       _controller.close();
  
positive.code:       _state = _State.FAILURE;
        // Report the error through the error callback if any. Otherwise
        // throw the error.
        error(new HttpException(
                    "Connection closed before full header was received"));
        _controller.close();
        return;
  
negative.code:     }
    }
  
    void _reportError(error, [stackTrace]) {
      if (_socketSubscription != null) _socketSubscription.cancel();
      _state = _State.FAILURE;
      _controller.addError(error, stackTrace);
  