anchor.diff:      _HttpDetachedIncoming detachedIncoming = _httpParser.detachIncoming();
   
       return _streamFuture.then((_) {
  -      _connections.remove(_serviceId);
         return new _DetachedSocket(_socket, detachedIncoming);
       });
     }
  
positive.code:   bool get _isActive => _state == _ACTIVE;
    bool get _isIdle => _state == _IDLE;
    bool get _isClosing => _state == _CLOSING;
  
    String get _serviceTypePath => 'io/http/serverconnections';
    String get _serviceTypeName => 'HttpServerConnection';
  
    Map _toJSON(bool ref) {
      var name = "${_socket.address.host}:${_socket.port} <-> "
          "${_socket.remoteAddress.host}:${_socket.remotePort}";
      var r = <String, dynamic>{
        'id': _servicePath,
        'type': _serviceType(ref),
        'name': name,
        'user_name': name,
      };
      if (ref) {
        return r;
      }
      r['server'] = _httpServer._toJSON(true);
      try {
        // TODO(kevmoo): don't rely on SDK implementation!
        r['socket'] = (_socket as dynamic)._toJSON(true);
      } catch (_) {
        r['socket'] = {
          'id': _servicePath,
          'type': '@Socket',
          'name': 'UserSocket',
          'user_name': 'UserSocket',
        };
      }
      switch (_state) {
        case _ACTIVE:
          r['state'] = "Active";
          break;
        case _IDLE:
          r['state'] = "Idle";
          break;
        case _CLOSING:
          r['state'] = "Closing";
          break;
        case _DETACHED:
          r['state'] = "Detached";
          break;
        default:
          r['state'] = 'Unknown';
          break;
      }
      return r;
    }
  }
  
  // HTTP server waiting for socket connections.
  class _HttpServer extends Stream<HttpRequest>
      with _ServiceObject
      implements HttpServer {
    // Use default Map so we keep order.
    static final Map<int, _HttpServer> _servers = new Map<int, _HttpServer>();
  
    String serverHeader;
    final HttpHeaders defaultResponseHeaders = _initDefaultResponseHeaders();
  
negative.code: 
    _HttpConnection(this._socket, this._httpServer)
        : _httpParser = new _HttpParser.requestParser() {
      _httpParser.listenToStream(_socket);
      _subscription = _httpParser.listen((incoming) {
        _httpServer._markActive(this);
  