assertThat(source.exhausted()).isTrue()
      assertThat(response.trailers()).isEqualTo(headersOf("trailers", "boom"))
    }
  }

  @Test
  fun connectionIsImmediatelyUnhealthy() {
    val listener: EventListener =
      object : EventListener() {
        override fun connectionAcquired(
          call: Call,
          connection: Connection,
        ) {