okhttp3.mockwebserver.MockResponse.getBody()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(4.4k)|赞(0)|评价(0)|浏览(106)

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

MockResponse.getBody介绍

[英]Returns a copy of the raw HTTP payload.
[中]返回原始HTTP有效负载的副本。

代码示例

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

private void pushPromises(Http2Stream stream, RecordedRequest request,
   List<PushPromise> promises) throws IOException {
  for (PushPromise pushPromise : promises) {
   List<Header> pushedHeaders = new ArrayList<>();
   pushedHeaders.add(new Header(Header.TARGET_AUTHORITY, url(pushPromise.path()).host()));
   pushedHeaders.add(new Header(Header.TARGET_METHOD, pushPromise.method()));
   pushedHeaders.add(new Header(Header.TARGET_PATH, pushPromise.path()));
   Headers pushPromiseHeaders = pushPromise.headers();
   for (int i = 0, size = pushPromiseHeaders.size(); i < size; i++) {
    pushedHeaders.add(new Header(pushPromiseHeaders.name(i), pushPromiseHeaders.value(i)));
   }
   String requestLine = pushPromise.method() + ' ' + pushPromise.path() + " HTTP/1.1";
   List<Integer> chunkSizes = Collections.emptyList(); // No chunked encoding for HTTP/2.
   requestQueue.add(new RecordedRequest(requestLine, pushPromise.headers(), chunkSizes, 0,
     new Buffer(), sequenceNumber.getAndIncrement(), socket));
   boolean hasBody = pushPromise.response().getBody() != null;
   Http2Stream pushedStream =
     stream.getConnection().pushStream(stream.getId(), pushedHeaders, hasBody);
   writeResponse(pushedStream, request, pushPromise.response());
  }
 }
}

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

private void writeHttpResponse(Socket socket, BufferedSink sink, MockResponse response)
  throws IOException {
 sleepIfDelayed(response.getHeadersDelay(TimeUnit.MILLISECONDS));
 sink.writeUtf8(response.getStatus());
 sink.writeUtf8("\r\n");
 writeHeaders(sink, response.getHeaders());
 Buffer body = response.getBody();
 if (body == null) return;
 sleepIfDelayed(response.getBodyDelay(TimeUnit.MILLISECONDS));
 throttledTransfer(response, socket, body, sink, body.size(), false);
 if ("chunked".equalsIgnoreCase(response.getHeaders().get("Transfer-Encoding"))) {
  writeHeaders(sink, response.getTrailers());
 }
}

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

Buffer body = response.getBody();
boolean outFinished = body == null
  && response.getPushPromises().isEmpty()

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

private void pushPromises(Http2Stream stream, List<PushPromise> promises) throws IOException {
  for (PushPromise pushPromise : promises) {
   List<Header> pushedHeaders = new ArrayList<>();
   pushedHeaders.add(new Header(Header.TARGET_AUTHORITY, url(pushPromise.path()).host()));
   pushedHeaders.add(new Header(Header.TARGET_METHOD, pushPromise.method()));
   pushedHeaders.add(new Header(Header.TARGET_PATH, pushPromise.path()));
   Headers pushPromiseHeaders = pushPromise.headers();
   for (int i = 0, size = pushPromiseHeaders.size(); i < size; i++) {
    pushedHeaders.add(new Header(pushPromiseHeaders.name(i), pushPromiseHeaders.value(i)));
   }
   String requestLine = pushPromise.method() + ' ' + pushPromise.path() + " HTTP/1.1";
   List<Integer> chunkSizes = Collections.emptyList(); // No chunked encoding for HTTP/2.
   requestQueue.add(new RecordedRequest(requestLine, pushPromise.headers(), chunkSizes, 0,
     new Buffer(), sequenceNumber.getAndIncrement(), socket));
   boolean hasBody = pushPromise.response().getBody() != null;
   Http2Stream pushedStream =
     stream.getConnection().pushStream(stream.getId(), pushedHeaders, hasBody);
   writeResponse(pushedStream, pushPromise.response());
  }
 }
}

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

private void writeHttpResponse(Socket socket, BufferedSink sink, MockResponse response)
  throws IOException {
 sleepIfDelayed(response.getBodyDelay(TimeUnit.MILLISECONDS));
 sink.writeUtf8(response.getStatus());
 sink.writeUtf8("\r\n");
 Headers headers = response.getHeaders();
 for (int i = 0, size = headers.size(); i < size; i++) {
  sink.writeUtf8(headers.name(i));
  sink.writeUtf8(": ");
  sink.writeUtf8(headers.value(i));
  sink.writeUtf8("\r\n");
 }
 sink.writeUtf8("\r\n");
 sink.flush();
 Buffer body = response.getBody();
 if (body == null) return;
 sleepIfDelayed(response.getBodyDelay(TimeUnit.MILLISECONDS));
 throttledTransfer(response, socket, body, sink, body.size(), false);
}

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

Buffer body = response.getBody();
boolean closeStreamAfterHeaders = body != null || !response.getPushPromises().isEmpty();
stream.sendResponseHeaders(http2Headers, closeStreamAfterHeaders);

相关文章