.isEqualTo("response F")
      requestBody.close()
      assertThat(responseBody.readUtf8Line()).isNull()
    }
    body.awaitSuccess()
  }

  @Test
  fun trueDuplexServerWritesFirst() {
    enableProtocol(Protocol.HTTP_2)
    val body =
      MockStreamHandler()
        .sendResponse("response A\n")
        .receiveRequest("request B\n")
        .sendResponse("response C\n")