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

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

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

MockResponse.setStatus介绍

暂无

代码示例

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

public MockResponse setResponseCode(int code) {
 String reason = "Mock Response";
 if (code >= 100 && code < 200) {
  reason = "Informational";
 } else if (code >= 200 && code < 300) {
  reason = "OK";
 } else if (code >= 300 && code < 400) {
  reason = "Redirection";
 } else if (code >= 400 && code < 500) {
  reason = "Client Error";
 } else if (code >= 500 && code < 600) {
  reason = "Server Error";
 }
 return setStatus("HTTP/1.1 " + code + " " + reason);
}

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

private MockResponse directoryToResponse(String basePath, File directory) {
 if (!basePath.endsWith("/")) basePath += "/";
 StringBuilder response = new StringBuilder();
 response.append(String.format("<html><head><title>%s</title></head><body>", basePath));
 response.append(String.format("<h1>%s</h1>", basePath));
 for (String file : directory.list()) {
  response.append(String.format("<div class='file'><a href='%s'>%s</a></div>",
    basePath + file, file));
 }
 response.append("</body></html>");
 return new MockResponse()
   .setStatus("HTTP/1.1 200")
   .addHeader("content-type: text/html; charset=utf-8")
   .setBody(response.toString());
}

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

/**
 * Attempts to perform a web socket upgrade on the connection. This will overwrite any previously
 * set status or body.
 */
public MockResponse withWebSocketUpgrade(WebSocketListener listener) {
 setStatus("HTTP/1.1 101 Switching Protocols");
 setHeader("Connection", "Upgrade");
 setHeader("Upgrade", "websocket");
 body = null;
 webSocketListener = listener;
 return this;
}

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

@Override public MockResponse dispatch(RecordedRequest request) {
 String path = request.getPath();
 try {
  if (!path.startsWith("/") || path.contains("..")) throw new FileNotFoundException();
  File file = new File(root + path);
  return file.isDirectory()
    ? directoryToResponse(path, file)
    : fileToResponse(path, file);
 } catch (FileNotFoundException e) {
  return new MockResponse()
    .setStatus("HTTP/1.1 404")
    .addHeader("content-type: text/plain; charset=utf-8")
    .setBody("NOT FOUND: " + path);
 } catch (IOException e) {
  return new MockResponse()
    .setStatus("HTTP/1.1 500")
    .addHeader("content-type: text/plain; charset=utf-8")
    .setBody("SERVER ERROR: " + e);
 }
}

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

private MockResponse fileToResponse(String path, File file) throws IOException {
 return new MockResponse()
   .setStatus("HTTP/1.1 200")
   .setBody(fileToBytes(file))
   .addHeader("content-type: " + contentType(path));
}

代码示例来源：origin: googlemaps/google-maps-services-java

private MockResponse createMockBadResponse() {
 MockResponse response = new MockResponse();
 response.setStatus("HTTP/1.1 500 Internal server error");
 response.setBody("Uh-oh. Server Error.");
 return response;
}

代码示例来源：origin: googlemaps/google-maps-services-java

@Test
public void testRetryEventuallyReturnsTheRightException() throws Exception {
 MockResponse errorResponse = new MockResponse();
 errorResponse.setStatus("HTTP/1.1 500 Internal server error");
 errorResponse.setBody("Uh-oh. Server Error.");
 // Enqueue some error responses.
 for (int i = 0; i < 10; i++) {
  server.enqueue(errorResponse);
 }
 server.start();
 // Wire the mock web server to the context
 setMockBaseUrl();
 builder.retryTimeout(5, TimeUnit.SECONDS);
 try {
  builder.build().get(new ApiConfig("/"), GeocodingApi.Response.class, "k", "v").await();
 } catch (IOException ioe) {
  // Ensure the message matches the status line in the mock responses.
  assertEquals("Server Error: 500 Internal server error", ioe.getMessage());
  return;
 }
 fail("Internal server error was expected but not observed.");
}

代码示例来源：origin: googlemaps/google-maps-services-java

@Test(expected = IOException.class)
public void testRetryCanBeDisabled() throws Exception {
 // Set up 2 mock responses, an error that shouldn't be retried and a success
 MockResponse errorResponse = new MockResponse();
 errorResponse.setStatus("HTTP/1.1 500 Internal server error");
 errorResponse.setBody("Uh-oh. Server Error.");
 server.enqueue(errorResponse);
 MockResponse goodResponse = new MockResponse();
 goodResponse.setResponseCode(200);
 goodResponse.setBody("{\n   \"results\" : [],\n   \"status\" : \"ZERO_RESULTS\"\n}");
 server.enqueue(goodResponse);
 server.start();
 setMockBaseUrl();
 // This should disable the retry, ensuring that the success response is NOT returned
 builder.disableRetries();
 // We should get the error response here, not the success response.
 builder.build().get(new ApiConfig("/"), GeocodingApi.Response.class, "k", "v").await();
}

代码示例来源：origin: googlemaps/google-maps-services-java

@Test
public void testToggleIfExceptionIsAllowedToRetry() throws Exception {
 // Enqueue some error responses, although only the first should be used because the response's
 // exception is not allowed to be retried.
 MockResponse overQueryLimitResponse = new MockResponse();
 overQueryLimitResponse.setStatus("HTTP/1.1 400 Internal server error");
 overQueryLimitResponse.setBody(TestUtils.retrieveBody("OverQueryLimitResponse.json"));
 server.enqueue(overQueryLimitResponse);
 server.enqueue(overQueryLimitResponse);
 server.enqueue(overQueryLimitResponse);
 server.start();
 builder.retryTimeout(1, TimeUnit.MILLISECONDS);
 builder.maxRetries(10);
 builder.setIfExceptionIsAllowedToRetry(OverQueryLimitException.class, false);
 setMockBaseUrl();
 try {
  builder
    .build()
    .get(new ApiConfig("/"), GeocodingApi.Response.class, "any-key", "any-value")
    .await();
 } catch (OverQueryLimitException e) {
  assertEquals(1, server.getRequestCount());
  return;
 }
 fail("OverQueryLimitException was expected but not observed.");
}

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

public MockResponse setResponseCode(int code) {
 String reason = "Mock Response";
 if (code >= 100 && code < 200) {
  reason = "Informational";
 } else if (code >= 200 && code < 300) {
  reason = "OK";
 } else if (code >= 300 && code < 400) {
  reason = "Redirection";
 } else if (code >= 400 && code < 500) {
  reason = "Client Error";
 } else if (code >= 500 && code < 600) {
  reason = "Server Error";
 }
 return setStatus("HTTP/1.1 " + code + " " + reason);
}

代码示例来源：origin: parse-community/Parse-SDK-Android

@Test
public void testParseOkHttpClientExecuteWithGZIPResponse() throws Exception {
  // Make mock response
  Buffer buffer = new Buffer();
  final ByteArrayOutputStream byteOut = new ByteArrayOutputStream();
  GZIPOutputStream gzipOut = new GZIPOutputStream(byteOut);
  gzipOut.write("content".getBytes());
  gzipOut.close();
  buffer.write(byteOut.toByteArray());
  MockResponse mockResponse = new MockResponse()
      .setStatus("HTTP/1.1 " + 201 + " " + "OK")
      .setBody(buffer)
      .setHeader("Content-Encoding", "gzip");
  // Start mock server
  server.enqueue(mockResponse);
  server.start();
  ParseHttpClient client = ParseHttpClient.createClient(new OkHttpClient.Builder());
  // We do not need to add Accept-Encoding header manually, httpClient library should do that.
  String requestUrl = server.url("/").toString();
  ParseHttpRequest parseRequest = new ParseHttpRequest.Builder()
      .setUrl(requestUrl)
      .setMethod(ParseHttpRequest.Method.GET)
      .build();
  // Execute request
  ParseHttpResponse parseResponse = client.execute(parseRequest);
  // Make sure the response we get is ungziped by OkHttp library
  byte[] content = ParseIOUtils.toByteArray(parseResponse.getContent());
  assertArrayEquals("content".getBytes(), content);
  server.shutdown();
}

代码示例来源：origin: parse-community/Parse-SDK-Android

buffer.write(byteOut.toByteArray());
MockResponse mockResponse = new MockResponse()
    .setStatus("HTTP/1.1 " + responseCode + " " + responseStatus)
    .setBody(buffer)
    .setHeader("Content-Encoding", "gzip");

代码示例来源：origin: parse-community/Parse-SDK-Android

.setStatus("HTTP/1.1 " + responseCode + " " + responseStatus)
.setBody(responseContent);

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

/**
 * Attempts to perform a web socket upgrade on the connection. This will overwrite any previously
 * set status or body.
 */
public MockResponse withWebSocketUpgrade(WebSocketListener listener) {
 setStatus("HTTP/1.1 101 Switching Protocols");
 setHeader("Connection", "Upgrade");
 setHeader("Upgrade", "websocket");
 body = null;
 webSocketListener = listener;
 return this;
}

代码示例来源：origin: Yelp/yelp-android

private void setUpMockServerResponse(int responseCode, String responseMessage, String responseBody) {
  MockResponse mockResponse = new MockResponse()
      .addHeader("Content-Type", "application/json; charset=utf-8")
      .setBody(responseBody)
      .setStatus(String.format("HTTP/1.1 %s %s", responseCode, responseMessage));
  mockServer.enqueue(mockResponse);
}

代码示例来源：origin: iagocanalejas/retrocache

@Test
public void http205SkipsConverter() throws IOException {
  final Converter<ResponseBody, String> converter = spy(
      new Converter<ResponseBody, String>() {
        @Override
        public String convert(ResponseBody value) throws IOException {
          return value.string();
        }
      });
  Retrofit retrofit = new Retrofit.Builder()
      .baseUrl(mServer.url("/"))
      .addConverterFactory(new ToStringConverterFactory() {
        @Override
        public Converter<ResponseBody, ?> responseBodyConverter(
            Type type,
            Annotation[] annotations,
            Retrofit retrofit) {
          return converter;
        }
      })
      .addCallAdapterFactory(buildSmartCacheFactory())
      .build();
  Service example = retrofit.create(Service.class);
  mServer.enqueue(new MockResponse().setStatus("HTTP/1.1 205 Nothin"));
  Response<String> response = example.getString().execute();
  assertThat(response.code()).isEqualTo(205);
  assertThat(response.body()).isNull();
  verifyNoMoreInteractions(converter);
}

代码示例来源：origin: iagocanalejas/retrocache

@Test
public void http204SkipsConverter() throws IOException {
  final Converter<ResponseBody, String> converter =
      spy(new Converter<ResponseBody, String>() {
        @Override
        public String convert(ResponseBody value) throws IOException {
          return value.string();
        }
      });
  Retrofit retrofit = new Retrofit.Builder()
      .baseUrl(mServer.url("/"))
      .addConverterFactory(new ToStringConverterFactory() {
        @Override
        public Converter<ResponseBody, ?> responseBodyConverter(
            Type type,
            Annotation[] annotations,
            Retrofit retrofit) {
          return converter;
        }
      })
      .addCallAdapterFactory(buildSmartCacheFactory())
      .build();
  Service example = retrofit.create(Service.class);
  mServer.enqueue(new MockResponse().setStatus("HTTP/1.1 204 Nothin"));
  Response<String> response = example.getString().execute();
  assertThat(response.code()).isEqualTo(204);
  assertThat(response.body()).isNull();
  verifyNoMoreInteractions(converter);
}

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

MockResponse

相关文章

    查看更多

    热门标签

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

    最新文章

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