val request = newRequest("http://a/1")
    executor.shutdown()
    client.newCall(request).enqueue(callback)
    callback.await(request.url).assertFailure(InterruptedIOException::class.java)
    assertThat(listener.recordedEventTypes())
      .containsExactly("CallStart", "CallFailed")
  }

  @Test
  fun executionRejectedAfterMaxRequestsChange() {
    val request1 = newRequest("http://a/1")
    val request2 = newRequest("http://a/2")

    server.close(1000, "")
    clientListener.assertClosing(1000, "")
    clientListener.assertClosed(1000, "")
    serverListener.assertClosed(1000, "")
    assertThat(listener.recordedEventTypes()).isEmpty()
  }

  @Test
  @Throws(Exception::class)
  fun callTimeoutAppliesToSetup() {
    webServer.enqueue(
      MockResponse.Builder()
        .headersDelay(500, TimeUnit.MILLISECONDS)

      client.newCall(request2).execute()
    }.also { expected ->
      assertThat(expected.message!!).startsWith("unexpected end of stream on http://")
    }

    assertThat(listener.recordedEventTypes()).containsExactly(
      "CallStart", "ConnectionAcquired", "RequestHeadersStart", "RequestHeadersEnd",
      "RequestBodyStart", "RequestBodyEnd", "ResponseFailed", "ConnectionReleased", "CallFailed",
    )