本文整理了Java中com.squareup.okhttp.mockwebserver.MockResponse.getBody()
方法的一些代码示例,展示了MockResponse.getBody()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MockResponse.getBody()
方法的具体详情如下:
包路径:com.squareup.okhttp.mockwebserver.MockResponse
类名称:MockResponse
方法名:getBody
[英]Returns a copy of the raw HTTP payload.
[中]返回原始HTTP有效负载的副本。
代码示例来源:origin: apache/jclouds
@Override
public MockResponse dispatch(RecordedRequest request) throws InterruptedException {
MockResponse response = responseQueue.take();
if (response.getBody() != null) {
/*
* "URL" must be used in the service catalog sample (such as
* access.json or accessRackspace.json) for the declared service
* endpoints.
*/
String newBody = urlTokenPattern.matcher(new String(response.getBody().readByteArray())).replaceAll(": \"" + url.toString());
response = response.setBody(newBody);
}
return response;
}
代码示例来源:origin: com.squareup.okhttp/mockwebserver
private void pushPromises(FramedStream stream, List<PushPromise> promises) throws IOException {
for (PushPromise pushPromise : promises) {
List<Header> pushedHeaders = new ArrayList<>();
pushedHeaders.add(new Header(stream.getConnection().getProtocol() == Protocol.SPDY_3
? Header.TARGET_HOST
: Header.TARGET_AUTHORITY, url(pushPromise.getPath()).host()));
pushedHeaders.add(new Header(Header.TARGET_METHOD, pushPromise.getMethod()));
pushedHeaders.add(new Header(Header.TARGET_PATH, pushPromise.getPath()));
Headers pushPromiseHeaders = pushPromise.getHeaders();
for (int i = 0, size = pushPromiseHeaders.size(); i < size; i++) {
pushedHeaders.add(new Header(pushPromiseHeaders.name(i), pushPromiseHeaders.value(i)));
}
String requestLine = pushPromise.getMethod() + ' ' + pushPromise.getPath() + " HTTP/1.1";
List<Integer> chunkSizes = Collections.emptyList(); // No chunked encoding for SPDY.
requestQueue.add(new RecordedRequest(requestLine, pushPromise.getHeaders(), chunkSizes, 0,
new Buffer(), sequenceNumber.getAndIncrement(), socket));
boolean hasBody = pushPromise.getResponse().getBody() != null;
FramedStream pushedStream =
stream.getConnection().pushStream(stream.getId(), pushedHeaders, hasBody);
writeResponse(pushedStream, pushPromise.getResponse());
}
}
}
代码示例来源:origin: com.squareup.okhttp/mockwebserver
Buffer body = response.getBody();
boolean closeStreamAfterHeaders = body != null || !response.getPushPromises().isEmpty();
stream.reply(spdyHeaders, closeStreamAfterHeaders);
代码示例来源:origin: com.squareup.okhttp/mockwebserver
private void writeHttpResponse(Socket socket, BufferedSink sink, MockResponse response)
throws IOException {
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);
throttledTransfer(response, socket, body, sink, body.size(), false);
}
内容来源于网络,如有侵权,请联系作者删除!