val requestBody = (call.request().body as AsyncRequestBody?)!!.takeSink()
      requestBody.writeUtf8("request body\n")
      requestBody.flush()
      val responseBody = response.body.source()
      assertThat(responseBody.readUtf8Line())
        .isEqualTo("response body")
      requestBody.close()
      assertThat(responseBody.readUtf8Line()).isNull()
    }
    body.awaitSuccess()
  }

  /**

   * quickly, possibly by handing off the provided request body to another thread to perform
   * writing.
   *
   * [grpc]: https://github.com/grpc/grpc/blob/master/doc/PROTOCOL-HTTP2.md
   */
  open fun isDuplex(): Boolean = false

  /**
   * Returns true if this body expects at most one call to [writeTo] and can be transmitted
   * at most once. This is typically used when writing the request body is destructive and it is not

    server.enqueue(MockResponse.Builder().body("abc").build())
    server.enqueue(MockResponse.Builder().body("def").build())
    val client =
      clientTestRule
        .newClientBuilder()
        .proxy(socksProxy.proxy())
        .build()
    val request1 = Request.Builder().url(server.url("/")).build()
    val response1 = client.newCall(request1).execute()
    assertThat(response1.body.string()).isEqualTo("abc")

     * @param body the request body containing synonym item information
     * @return JSON response with result status
     */
    // POST /api/admin/dict/synonym/setting/{dictId}
    @Execute
    public JsonResponse<ApiResult> post$setting(final String dictId, final CreateBody body) {
        body.dictId = dictId;
        validateApi(body, messages -> {});
        body.crudMode = CrudMode.CREATE;

    assertThat(body.name(1)).isEqualTo("space, the")
    assertThat(body.name(2)).isEqualTo("%25")
    assertThat(body.encodedValue(0)).isEqualTo("c%2B%3D%26+d")
    assertThat(body.encodedValue(1)).isEqualTo("final+frontier")
    assertThat(body.encodedValue(2)).isEqualTo("%2525")
    assertThat(body.value(0)).isEqualTo("c+=& d")
    assertThat(body.value(1)).isEqualTo("final frontier")
    assertThat(body.value(2)).isEqualTo("%25")

   * time.
   */
  @Test
  fun readTimeoutOnSlowConnection() {
    val body = repeat('y', 2048)
    server.enqueue(
      MockResponse
        .Builder()
        .body(body)
        .throttleBody(1024, 1, TimeUnit.SECONDS)
        .build(),
    ) // Slow connection 1KiB/second.
    server.enqueue(
      MockResponse(body = body),
    )
    client =
      client
        .newBuilder()

    assertThat(response2.body.string()).isEqualTo("def")
    val get = server.takeRequest()
    assertThat(get.exchangeIndex).isEqualTo(0)
    val post1 = server.takeRequest()
    assertThat(post1.body?.utf8()).isEqualTo("body!")
    assertThat(post1.exchangeIndex).isEqualTo(1)
    val post2 = server.takeRequest()
    assertThat(post2.body?.utf8()).isEqualTo("body!")
    assertThat(post2.exchangeIndex).isEqualTo(0)

        Request(
          url = server.url("/"),
          body = body.toRequestBody(),
        ),
      )
    assertThat(response.code).isEqualTo(200)
    response.body.byteStream().close()
    val recordedRequest1 = server.takeRequest()
    assertThat(recordedRequest1.method).isEqualTo("POST")
    assertThat(recordedRequest1.body?.utf8()).isEqualTo(body)
    assertThat(recordedRequest1.headers["Authorization"]).isNull()

def test_body_repr_str():
    assert repr(Body("teststr")) == "Body(teststr)"


def test_body_repr_none():
    assert repr(Body(None)) == "Body(None)"


def test_body_repr_ellipsis():
    assert repr(Body(...)) == "Body(PydanticUndefined)"


def test_body_repr_number():
    assert repr(Body(1)) == "Body(1)"


def test_body_repr_list():

     *
     * @param body path mapping setting data to create
     * @return JSON response with created setting ID and status
     */
    @Execute
    public JsonResponse<ApiResult> post$setting(final CreateBody body) {
        validateApi(body, messages -> {});
        body.crudMode = CrudMode.CREATE;
        final PathMapping entity = getPathMapping(body).orElseGet(() -> {