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