code: @Override
    public void processEvents() throws IOException, EncodingException {
      if (!getIsConnected()) {
        LOGGER.warning("Not connnected...");
      }
  
      while (true) {
        ByteBuffer block = null;
        synchronized (receiveBuffer) {
          if (!receiveBuffer.isEmpty()) {
            block = receiveBuffer.remove(0);
          }
        }
        if (block == null) {
          break;
        }
        elementReader.onReceivedData(block);
      }
    }
docs: {@inheritDoc}