anchor.diff:      if (_controller.hasListener) {
         _resume();
       } else {
  -      close();
  +      _socket.close();
       }
     }
   }
  
positive.code:     activateHandlers();
    }
  
    Future<_NativeSocket> get closeFuture => closeCompleter.future;
  
    void activateHandlers() {
      if (canActivateEvents && !isClosing && !isClosed) {
  
negative.code:         onCancel: _onSubscriptionStateChange,
          onPause: _onPauseStateChange,
          onResume: _onPauseStateChange);
      _socket.setHandlers(
        read: () => _controller.add(RawSocketEvent.READ),
        write: () {
  