anchor.diff:    _releaseLock(String requestId, String callId, String lockType, Socket socket) {
       if (_tryReleaseLock(requestId, callId, lockType, socket)) {
         writeJSON(socket, {"result":"ok", "action":"release", "requestId":requestId});
  +      socket.flush().catchError((e, s) => _logger.warning("error when flushing in socket ${s.hashCode} $e $s"));
         checkLockRequestors();
       } else {
         writeJSON(socket, {"error": "Cannot release lock when the socket does not own it", "action":"release", "requestId":requestId});
  +      socket.flush().catchError((e, s) => _logger.warning("error when flushing in socket ${s.hashCode} $e $s"));
       }
     }
   
  
positive.code:         currentLock[lockType]['timestamp'] = new DateTime.now();
          _logger.fine('Lock type $lockType acquired');
          writeJSON(currentLock[lockType]["socket"], {"result":"ok", "action":"get", "requestId": currentLock[lockType]["requestId"]});
        }
      });
  
  
negative.code:   }
  
    handleClient(Socket socket) {
      _logger.info("New socket come: ${socket.hashCode}");
      socket.done.catchError((e,s) => _logger.info("Soccet ${socket.hashCode} done error $e $s "));
      clientSockets.add(socket);
      toJsonStream(socket).listen((Map data) {
        if (data["type"] == "lock") handleLockRequest(data["data"], socket);
        if (data["type"] == "info") handleInfoRequest(socket);
      }, onDone: () => _disposeOfSocket(socket)
       , onError: (e,s) => _logger.warning("Error on listening on stream ${s.hashCode}"));
    }
  
    handleInfoRequest(Socket socket) {
  