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

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

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

MockResponse.getSocketPolicy介绍

暂无

代码示例

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

private void acceptConnections() throws Exception {
  while (true) {
   Socket socket;
   try {
    socket = serverSocket.accept();
   } catch (SocketException e) {
    logger.info(MockWebServer.this + " done accepting connections: " + e.getMessage());
    return;
   }
   SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
   if (socketPolicy == DISCONNECT_AT_START) {
    dispatchBookkeepingRequest(0, socket);
    socket.close();
   } else {
    openClientSockets.add(socket);
    serveConnection(socket);
   }
  }
 }
});

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

if (response.getSocketPolicy() == DISCONNECT_AFTER_REQUEST) {
 socket.close();
 return false;
if (response.getSocketPolicy() == NO_RESPONSE) {
if (response.getSocketPolicy() == DISCONNECT_AT_END) {
 socket.close();
 return false;
} else if (response.getSocketPolicy() == SHUTDOWN_INPUT_AT_END) {
 socket.shutdownInput();
} else if (response.getSocketPolicy() == SHUTDOWN_OUTPUT_AT_END) {
 socket.shutdownOutput();
} else if (response.getSocketPolicy() == SHUTDOWN_SERVER_AFTER_RESPONSE) {
 shutdown();

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

/**
 * Respond to CONNECT requests until a SWITCH_TO_SSL_AT_END response is
 * dispatched.
 */
private void createTunnel() throws IOException, InterruptedException {
 BufferedSource source = Okio.buffer(Okio.source(raw));
 BufferedSink sink = Okio.buffer(Okio.sink(raw));
 while (true) {
  SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
  if (!processOneRequest(raw, source, sink)) {
   throw new IllegalStateException("Tunnel without any CONNECT!");
  }
  if (socketPolicy == UPGRADE_TO_SSL_AT_END) return;
 }
}

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

? policy.getSocketPolicy() == DISCONNECT_DURING_REQUEST_BODY
: policy.getSocketPolicy() == DISCONNECT_DURING_RESPONSE_BODY;

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

@Override public void onStream(Http2Stream stream) throws IOException {
 MockResponse peekedResponse = dispatcher.peek();
 if (peekedResponse.getSocketPolicy() == RESET_STREAM_AT_START) {
  try {
   dispatchBookkeepingRequest(sequenceNumber.getAndIncrement(), socket);
  throw new AssertionError(e);
 if (response.getSocketPolicy() == DISCONNECT_AFTER_REQUEST) {
  socket.close();
  return;
 if (response.getSocketPolicy() == DISCONNECT_AT_END) {
  Http2Connection connection = stream.getConnection();
  connection.shutdown(ErrorCode.NO_ERROR);

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

final SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
if (expectContinue && socketPolicy == EXPECT_CONTINUE || socketPolicy == CONTINUE_ALWAYS) {
 sink.writeUtf8("HTTP/1.1 100 Continue\r\n");

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

public void processConnection() throws Exception {
 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
 Protocol protocol = Protocol.HTTP_1_1;
 Socket socket;

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

if (peek.isDuplex()) {
 readBody = false;
} else if (!readBody && peek.getSocketPolicy() == EXPECT_CONTINUE) {
 List<Header> continueHeaders = Collections.singletonList(
   new Header(Header.RESPONSE_STATUS, ByteString.encodeUtf8("100 Continue")));

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

if (response.getSocketPolicy() == NO_RESPONSE) {
 return;

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

private void acceptConnections() throws Exception {
  while (true) {
   Socket socket;
   try {
    socket = serverSocket.accept();
   } catch (SocketException e) {
    logger.info(MockWebServer.this + " done accepting connections: " + e.getMessage());
    return;
   }
   SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
   if (socketPolicy == DISCONNECT_AT_START) {
    dispatchBookkeepingRequest(0, socket);
    socket.close();
   } else {
    openClientSockets.add(socket);
    serveConnection(socket);
   }
  }
 }
});

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

if (response.getSocketPolicy() == DISCONNECT_AFTER_REQUEST) {
 socket.close();
 return false;
if (response.getSocketPolicy() == NO_RESPONSE) {
if (response.getSocketPolicy() == DISCONNECT_AT_END) {
 socket.close();
 return false;
} else if (response.getSocketPolicy() == SHUTDOWN_INPUT_AT_END) {
 socket.shutdownInput();
} else if (response.getSocketPolicy() == SHUTDOWN_OUTPUT_AT_END) {
 socket.shutdownOutput();

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

/**
 * Respond to CONNECT requests until a SWITCH_TO_SSL_AT_END response is
 * dispatched.
 */
private void createTunnel() throws IOException, InterruptedException {
 BufferedSource source = Okio.buffer(Okio.source(raw));
 BufferedSink sink = Okio.buffer(Okio.sink(raw));
 while (true) {
  SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
  if (!processOneRequest(raw, source, sink)) {
   throw new IllegalStateException("Tunnel without any CONNECT!");
  }
  if (socketPolicy == UPGRADE_TO_SSL_AT_END) return;
 }
}

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

? policy.getSocketPolicy() == DISCONNECT_DURING_REQUEST_BODY
: policy.getSocketPolicy() == DISCONNECT_DURING_RESPONSE_BODY;

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

@Override public void onStream(Http2Stream stream) throws IOException {
 MockResponse peekedResponse = dispatcher.peek();
 if (peekedResponse.getSocketPolicy() == RESET_STREAM_AT_START) {
  try {
   dispatchBookkeepingRequest(sequenceNumber.getAndIncrement(), socket);
  throw new AssertionError(e);
 if (response.getSocketPolicy() == DISCONNECT_AFTER_REQUEST) {
  socket.close();
  return;
 if (response.getSocketPolicy() == DISCONNECT_AT_END) {
  Http2Connection connection = stream.getConnection();
  connection.shutdown(ErrorCode.NO_ERROR);

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

if (expectContinue && dispatcher.peek().getSocketPolicy() == EXPECT_CONTINUE) {
 sink.writeUtf8("HTTP/1.1 100 Continue\r\n");
 sink.writeUtf8("Content-Length: 0\r\n");

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

createTunnel();
SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
if (socketPolicy == FAIL_HANDSHAKE) {
 dispatchBookkeepingRequest(sequenceNumber, raw);

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

if (!readBody && peek.getSocketPolicy() == EXPECT_CONTINUE) {
 stream.sendResponseHeaders(Collections.singletonList(
   new Header(Header.RESPONSE_STATUS, ByteString.encodeUtf8("100 Continue"))), true);

代码示例来源：origin: orhanobut/mockwebserverplus

@Test public void enqueueSocketPolicy() throws IOException {
 server.enqueue(SocketPolicy.KEEP_OPEN);
 QueueDispatcher dispatcher = new QueueDispatcher();
 server.setDispatcher(dispatcher);
 MockResponse mockResponse = dispatcher.peek();
 assertThat(mockResponse.getSocketPolicy()).isEqualTo(SocketPolicy.KEEP_OPEN);
}

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

if (response.getSocketPolicy() == NO_RESPONSE) {
 return;

内容来源于网络，如有侵权，请联系作者删除！

MockResponse

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com