docs: public boolean waitForInitialCreate(long timeout, TimeUnit unit) throws InterruptedException
      {
          Preconditions.checkState(state.get() == State.STARTED, "Not started");
  
          CountDownLatch localLatch = initialCreateLatch.get();
          return (localLatch == null) || localLatch.await(timeout, unit);
      }