}
  }

  @Test
  fun failedCall() {
    runTest {
      server.enqueue(
        MockResponse
          .Builder()
          .body("abc")
          .onResponseStart(SocketEffect.ShutdownConnection)
          .build(),
      )

      val call = client.newCall(request)

      assertFailsWith<IOException> {
        call.executeAsync().use {

      result.onResponseEnd(ShutdownConnection)
    }

    SocketPolicy.DISCONNECT_AT_START -> {
      result.onRequestStart(CloseSocket())
    }

    SocketPolicy.DISCONNECT_AFTER_REQUEST -> {
      result.onResponseStart(CloseSocket())
    }

    SocketPolicy.DISCONNECT_DURING_REQUEST_BODY -> {
      result.onRequestBody(CloseSocket())
    }

    SocketPolicy.DISCONNECT_DURING_RESPONSE_BODY -> {