docs: private void addSinkTasks() {
      Runnable sinkTasks = new Runnable() {
        @Override
        public void run() {
          while (!metricsInSinkQueue.isEmpty()) {
            metricsSink.processRecord(metricsInSinkQueue.poll());
          }
        }
      };
  
      slaveLooper.addTasksOnWakeup(sinkTasks);
    }