CountDownLatch gotException = new CountDownLatch(1);
    AsyncFunction<String, String> function =
        unused -> {
          inFunction.countDown();
          try {
            shouldCompleteFunction.await();
          } catch (InterruptedException expected) {
            gotException.countDown();
            throw expected;
          }
          return immediateFuture("a");
        };

    CountDownLatch gotException = new CountDownLatch(1);
    AsyncFunction<String, String> function =
        unused -> {
          inFunction.countDown();
          try {
            shouldCompleteFunction.await();
          } catch (InterruptedException expected) {
            gotException.countDown();
            throw expected;
          }
          return immediateFuture("a");
        };

          throw new RuntimeException(e);
        }
        doneSignal.countDown();
      }
    }.start();

    try {
      computingSignal.await();
    } catch (InterruptedException e) {
      throw new RuntimeException(e);
    }

    map.put(one, two);
    assertThat(map.get(one)).isSameInstanceAs(two);
    startSignal.countDown();

    try {
      doneSignal.await();

          throw new RuntimeException(e);
        }
        doneSignal.countDown();
      }
    }.start();

    try {
      computingSignal.await();
    } catch (InterruptedException e) {
      throw new RuntimeException(e);
    }

    map.put(one, two);
    assertThat(map.get(one)).isSameInstanceAs(two);
    startSignal.countDown();

    try {
      doneSignal.await();

    val requestFinishedListener =
      object : EventListener() {
        override fun requestHeadersEnd(
          call: Call,
          request: Request,
        ) {
          requestFinished.countDown()
        }
      }
    client =
      client
        .newBuilder()
        .dns(DoubleInetAddressDns())
        .eventListenerFactory(

      }
      for (Map.Entry<AutoCloseable, Executor> entry : entrySet()) {
        closeQuietly(entry.getKey(), entry.getValue());
      }
      clear();
      if (whenClosed != null) {
        whenClosed.countDown();
      }
    }

    void add(@Nullable AutoCloseable closeable, Executor executor) {
      checkNotNull(executor);
      if (closeable == null) {
        return;
      }