private void scheduleThrottlingFlush() {
    if (throttlingFlushFuture != null && !throttlingFlushFuture.isDone()) return;
    Runnable command = () -> {
      if (ContainerUtil.and(contributorsMap.values(), Boolean::booleanValue)) {
        cancelFlushTask(timeoutFlushFuture);
        flushBuffer(false);
      }
    };
    throttlingFlushFuture = executorService.schedule(command, throttlingTimeoutMs, TimeUnit.MILLISECONDS);
  }
private void scheduleThrottlingFlush()