anchor.diff:      }, onDone: () => _disposeOfSocket(socket)
        , onError: (e,s) => _logger.warning("Error on listening on stream ${s.hashCode}"));
     }
  +
  +  _flushAndCatchError(socket) =>
  +      socket.flush().catchError((e, s) => _logger.warning("error when flushing in socket ${s.hashCode} $e $s"));
   
     handleInfoRequest(Socket socket) {
       getProperInfo(Map map) =>
  
positive.code:     if (_tryReleaseLock(requestId, callId, lockType, socket) ||
          _tryCancelRequestor(requestId, callId, lockType, socket)) {
        writeJSON(socket, {"result": "ok", "action": "cancel", "requestId": requestId});
        socket.flush().catchError((e, s) => _logger.warning("error when flushing in socket ${s.hashCode} $e $s"));
      } else {
        writeJSON(socket, {"error": "Cannot cancel requestor when the socket does not own it nor waits for it", "action": "cancel", "requestId": requestId});
        socket.flush().catchError((e, s) => _logger.warning("error when flushing in socket ${s.hashCode} $e $s"));
      }
    }
  
    // Checks if someone can be given their requested lockType
  
negative.code:   static Future<Locker> bind(url, port) =>
        ServerSocket.bind(url, port)
          .then((ServerSocket sSocket) {
            _logger.info('Locker running on $url, $port');
            Locker locker = new Locker.config(sSocket);
            locker.serverSocket.listen(locker.handleClient);
            return locker;
  