CallTest.java 文件源码

@Test public void requestBodyRetransmittedOnClientRequestTimeout() throws Exception {
  server.enqueue(new MockResponse()
      .setSocketPolicy(SocketPolicy.DISCONNECT_AT_END)
      .setResponseCode(408)
      .setHeader("Connection", "Close")
      .setBody("You took too long!"));
  server.enqueue(new MockResponse().setBody("Body"));

  Request request = new Request.Builder()
      .url(server.url("/"))
      .post(RequestBody.create(MediaType.parse("text/plain"), "Hello"))
      .build();
  Response response = client.newCall(request).execute();

  assertEquals("Body", response.body().string());

  RecordedRequest request1 = server.takeRequest();
  assertEquals("Hello", request1.getBody().readUtf8());

  RecordedRequest request2 = server.takeRequest();
  assertEquals("Hello", request2.getBody().readUtf8());
}