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:         currentLock[lockType]['timestamp'] = new DateTime.now();
          _logger.fine('Lock type $lockType acquired');
          writeJSON(currentLock[lockType]["socket"], {"result":"ok", "action":"get", "requestId": currentLock[lockType]["requestId"]});
          currentLock[lockType]["socket"].flush().catchError((e, s) => _logger.warning("error when flushing in socket ${s.hashCode} $e $s"));
        }
      });
  
  
negative.code:   _releaseLock(String requestId, String callId, String lockType, Socket socket) {
      if (_tryReleaseLock(requestId, callId, lockType, socket)) {
        writeJSON(socket, {"result":"ok", "action":"release", "requestId":requestId});
        checkLockRequestors();
      } else {
        writeJSON(socket, {"error": "Cannot release lock when the socket does not own it", "action":"release", "requestId":requestId});
      }
      _flushAndCatchError(socket);
    }
  
    _tryCancelRequestor(String requestId, String callId, String lockType, Socket socket) {
  