void () { 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); }