anchor.diff:      // If the connection is idle the HTTP stream is closed.
       if (_state == _State.START) {
         if (!_requestParser) {
  -        error(new HttpException(
  +        _reportError(new HttpException(
                       "Connection closed before full header was received"));
         }
         _controller.close();
  
positive.code:       _doParse();
      } catch (e, s) {
        _state = _State.FAILURE;
        error(e, s);
      }
    }
  
  
negative.code:     }
    }
  
    void _reportError(error, [stackTrace]) {
      if (_socketSubscription != null) _socketSubscription.cancel();
      _state = _State.FAILURE;
      _controller.addError(error, stackTrace);
  