public Object load(String key) throws InterruptedException {
                callCount.incrementAndGet();
                startSignal.await();
                return result;
              }
            });

    List<Object> resultArray = doConcurrentGet(cache, "bar", count, startSignal);

    assertEquals(1, callCount.get());
    for (int i = 0; i < count; i++) {

          clientTestRule.wrap(
            object : EventListener() {
              var callCount = 0

              override fun connectionAcquired(
                call: Call,
                connection: Connection,
              ) {
                try {
                  if (callCount++ == 1) {
                    server.close()
                  }
                } catch (e: IOException) {