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

MockResponse.throttleBody介绍

[英]Throttles the request reader and response writer to sleep for the given period after each series of bytesPerPeriod bytes are transferred. Use this to simulate network behavior.
[中]在传输每个BytesPerPerPerPerPeriod字节序列后，在给定的时间段内限制请求读取器和响应写入器睡眠。使用此选项模拟网络行为。

代码示例

代码示例来源：origin: stackoverflow.com

MockResponse response = new MockResponse()
  .addHeader("Content-Type", "application/json; charset=utf-8")
  .addHeader("Cache-Control", "no-cache")
  .setBody("{}");
response.throttleBody(1024, 1, TimeUnit.SECONDS);

代码示例来源：origin: bumptech/glide

@Test
public void testSetsReadTimeout() throws Exception {
 MockWebServer tempWebServer = new MockWebServer();
 tempWebServer.enqueue(
   new MockResponse().setBody("test").throttleBody(1, TIMEOUT_TIME_MS, TimeUnit.MILLISECONDS));
 tempWebServer.start();
 try {
  getFetcher().loadData(Priority.HIGH, callback);
 } finally {
  tempWebServer.shutdown();
  // shutdown() called before any enqueue() blocks until it times out.
  mockWebServer.enqueue(new MockResponse().setResponseCode(200));
 }
 verify(callback).onLoadFailed(isA(IOException.class));
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void override_timeout_on_post() {
 underTest = HttpConnector.newBuilder().url(serverUrl).build();
 // Headers are not affected by setBodyDelay, let's throttle the answer
 server.enqueue(new MockResponse().throttleBody(1,100, TimeUnit.MILLISECONDS).setBody("Hello delayed"));
 expectedException.expect(IllegalStateException.class);
 expectedException.expectCause(IsInstanceOf.instanceOf(SocketTimeoutException.class));
 WsResponse call = underTest.call(new PostRequest("/").setTimeOutInMs(5));
 assertThat(call.content()).equals("Hello delayed");
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void override_timeout_on_post_with_redirect() {
 underTest = HttpConnector.newBuilder().url(serverUrl).build();
 server.enqueue(new MockResponse().setResponseCode(301).setHeader("Location:", "/redirect"));
 // Headers are not affected by setBodyDelay, let's throttle the answer
 server.enqueue(new MockResponse().throttleBody(1,100, TimeUnit.MILLISECONDS).setBody("Hello delayed"));
 expectedException.expect(IllegalStateException.class);
 expectedException.expectCause(IsInstanceOf.instanceOf(SocketTimeoutException.class));
 WsResponse call = underTest.call(new PostRequest("/").setTimeOutInMs(5));
 assertThat(call.content()).equals("Hello delayed");
}

代码示例来源：origin: ragdroid/mockstar

@Test
public void testDemoResponseErrorSocket() {
  reset(mainSceneMock);
  MainPresenterImpl presenter = new MainPresenterImpl(schedulersProvider, pokeDataSource);
  MockResponse response = new MockResponse();
  response.setBody("\"message\":\"Hello\"").throttleBody(1, 2, TimeUnit.SECONDS);
  getErrorMockWebServer().enqueue(response);
  presenter.onSceneAdded(mainSceneMock, null);
  testScheduler.triggerActions();
  verify(mainSceneMock, times(1)).showErrorDialog(anyString());
  verify(mainSceneMock, times(0)).setApiText(anyString());
}

代码示例来源：origin: xing/xing-android-sdk

server.enqueue(new MockResponse().throttleBody(1, 1, TimeUnit.SECONDS));