本文整理了Java中okhttp3.mockwebserver.MockResponse.setChunkedBody()方法的一些代码示例，展示了MockResponse.setChunkedBody()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。MockResponse.setChunkedBody()方法的具体详情如下：
包路径：okhttp3.mockwebserver.MockResponse
类名称：MockResponse
方法名：setChunkedBody

MockResponse.setChunkedBody介绍

[英]Sets the response body to the UTF-8 encoded bytes of body, chunked every maxChunkSize bytes.
[中]将响应正文设置为正文的UTF-8编码字节，每个maxChunkSize字节分块。

代码示例

代码示例来源：origin: square/okhttp

/**
 * Sets the response body to the UTF-8 encoded bytes of {@code body}, chunked every {@code
 * maxChunkSize} bytes.
 */
public MockResponse setChunkedBody(String body, int maxChunkSize) {
 return setChunkedBody(new Buffer().writeUtf8(body), maxChunkSize);
}

代码示例来源：origin: spring-projects/spring-framework

@Test // SPR-17482
public void bodyToMonoVoidWithoutContentType() {
  this.server.enqueue(new MockResponse()
      .setResponseCode(HttpStatus.ACCEPTED.value())
      .setChunkedBody("{\"foo\" : \"123\",  \"baz\" : \"456\", \"baz\" : \"456\"}", 5));
  Mono<Map<String, String>> mono = this.webClient.get()
      .uri("/sample").accept(MediaType.APPLICATION_JSON)
      .retrieve()
      .bodyToMono(new ParameterizedTypeReference<Map<String, String>>() {});
  StepVerifier.create(mono).expectError(UnsupportedMediaTypeException.class).verify(Duration.ofSeconds(3));
  assertEquals(1, this.server.getRequestCount());
}

代码示例来源：origin: spring-projects/spring-framework

@Test
public void bodyToMonoVoid() {
  this.server.enqueue(new MockResponse()
      .setResponseCode(201)
      .setHeader("Content-Type", "application/json")
      .setChunkedBody("{\"foo\" : {\"bar\" : \"123\", \"baz\" : \"456\"}}", 5));
  Mono<Void> mono = this.webClient.get()
      .uri("/json").accept(MediaType.APPLICATION_JSON)
      .retrieve()
      .bodyToMono(Void.class);
  StepVerifier.create(mono).expectComplete().verify(Duration.ofSeconds(3));
  assertEquals(1, this.server.getRequestCount());
}

代码示例来源：origin: spring-projects/spring-framework

private void testOnStatus(Throwable expected,
    Function<ClientResponse, Mono<? extends Throwable>> exceptionFunction) {
  HttpStatus errorStatus = HttpStatus.BAD_GATEWAY;
  this.server.enqueue(new MockResponse()
      .setResponseCode(errorStatus.value())
      .setHeader("Content-Type", "application/json")
      .setChunkedBody("{\"error\" : {\"status\" : 502, \"message\" : \"Bad gateway.\"}}", 5));
  Mono<String> mono = this.webClient.get()
      .uri("/json").accept(MediaType.APPLICATION_JSON)
      .retrieve()
      .onStatus(status -> status.equals(errorStatus), exceptionFunction)
      .bodyToMono(String.class);
  StepVerifier.create(mono).expectErrorSatisfies(actual -> assertSame(expected, actual)).verify(DELAY);
  assertEquals(1, this.server.getRequestCount());
}

代码示例来源：origin: com.github.ljun20160606/mockwebserver

/**
 * Sets the response body to the UTF-8 encoded bytes of {@code body}, chunked every {@code
 * maxChunkSize} bytes.
 */
public MockResponse setChunkedBody(String body, int maxChunkSize) {
 return setChunkedBody(new Buffer().writeUtf8(body), maxChunkSize);
}

代码示例来源：origin: fabric8io/mockwebserver

public MockResponse toMockResponse(RecordedRequest request) {
  MockResponse mockResponse = new MockResponse();
  mockResponse.setHeaders(bodyProvider.getHeaders());
  mockResponse.setChunkedBody(concatBody(request), DEFAULT_MAX_CHUNK_SIZE);
  mockResponse.setResponseCode(bodyProvider.getStatusCode());
  if (responseDelay > 0) {
    mockResponse.setBodyDelay(responseDelay, responseDelayUnit);
  }
  return mockResponse;
}