assertThat(server.takeRequest().exchangeIndex).isEqualTo(1)
    // New connection.
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
  }

  @Test
  fun recoverFromCancelReusesConnection() {
    val responseDequeuedLatches =
      listOf(
        // No synchronization for the last request, which is not canceled:
        CountDownLatch(1),
        CountDownLatch(0),
      )