docs: private void cleanUpOnce() {
     if (!cleaned.compareAndSet(false, true)) {
          return;
     }
  
      try {
        closeQuietly(pumper);
        shutdownExecutorService(executorService);
      } finally {
        closeQuietly(toClose);
      }
    }