anchor.diff:          onCancel: _onSubscriptionStateChange,
           onPause: _onPauseStateChange,
           onResume: _onPauseStateChange);
  -    _socket.closeFuture.then((_) => _controller.close());
       _socket.setHandlers(
         read: zone.bindCallback(() {
           var socket = _socket.accept();
  
positive.code:         if (i == DESTROYED_EVENT) {
            assert(!isClosed);
            isClosed = true;
            closeCompleter.complete(this);
            disconnectFromEventHandler();
            if (handler != null) handler();
            continue;
  
negative.code:         onCancel: _onSubscriptionStateChange,
          onPause: _onPauseStateChange,
          onResume: _onPauseStateChange);
      _socket.setHandlers(
        read: () => _controller.add(RawSocketEvent.READ),
        write: () {
  