com.squareup.okhttp.mockwebserver.MockWebServer类的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(8.2k)|赞(0)|评价(0)|浏览(170)

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

MockWebServer介绍

[英]A scriptable web server. Callers supply canned responses and the server replays them upon request in sequence.
[中]可编写脚本的web服务器。呼叫者提供固定的响应,服务器根据请求按顺序重播这些响应。

代码示例

代码示例来源:origin: facebook/stetho

hookAlmostRealRequestWillBeSent(mMockEventReporter);
MockWebServer server = new MockWebServer();
server.start();
server.enqueue(new MockResponse()
  .setBody("Success!"));
  compress(decompressed));
Request request = new Request.Builder()
  .url(server.getUrl("/"))
  .addHeader("Content-Encoding", "gzip")
  .post(compressedBody)
    eq(compressed.length));
server.shutdown();

代码示例来源:origin: google/data-transfer-project

@Test
@SuppressWarnings("unchecked")
public void testImport() throws Exception {
 server.enqueue(new MockResponse().setBody(BATCH_CALENDAR_RESPONSE));
 server.enqueue(new MockResponse().setResponseCode(201).setBody(BATCH_EVENT_RESPONSE));
 server.start();
 HttpUrl baseUrl = server.url("");
 MicrosoftCalendarImporter importer =
   new MicrosoftCalendarImporter(
 RecordedRequest calendarBatch = server.takeRequest();
 Map<String, Object> calendarBody =
   (Map<String, Object>) mapper.readValue(calendarBatch.getBody().readUtf8(), Map.class);
 RecordedRequest eventBatch = server.takeRequest();
 Map<String, Object> eventRequests =
   (Map<String, Object>) mapper.readValue(eventBatch.getBody().readUtf8(), Map.class);

代码示例来源:origin: facebook/stetho

@Test
public void testWithResponseCompression() throws IOException {
 ByteArrayOutputStream capturedOutput = hookAlmostRealInterpretResponseStream(mMockEventReporter);
 byte[] uncompressedData = repeat(".", 1024).getBytes();
 byte[] compressedData = compress(uncompressedData);
 MockWebServer server = new MockWebServer();
 server.start();
 server.enqueue(new MockResponse()
   .setBody(new Buffer().write(compressedData))
   .addHeader("Content-Encoding: gzip"));
 Request request = new Request.Builder()
   .url(server.url("/"))
   .build();
 Response response = mClientWithInterceptor.newCall(request).execute();
 // Verify that the final output and the caller both saw the uncompressed stream.
 assertArrayEquals(uncompressedData, response.body().bytes());
 assertArrayEquals(uncompressedData, capturedOutput.toByteArray());
 // And verify that the StethoInterceptor was able to see both.
 Mockito.verify(mMockEventReporter)
   .dataReceived(
     anyString(),
     eq(compressedData.length),
     eq(uncompressedData.length));
 server.shutdown();
}

代码示例来源:origin: google/data-transfer-project

@Test
public void testExport() throws Exception {
 server.enqueue(new MockResponse().setBody(CALENDARS_RESPONSE));
 server.enqueue(new MockResponse().setBody(CALENDAR1_EVENTS_RESPONSE));
 server.enqueue(new MockResponse().setBody(CALENDAR2_EVENTS_RESPONSE));
 server.start();
 HttpUrl baseUrl = server.url("");
 MicrosoftCalendarExporter exporter =
   new MicrosoftCalendarExporter(baseUrl.toString(), client, mapper, transformerService);
 ExportResult<CalendarContainerResource> resource = exporter
   .export(UUID.randomUUID(), token, Optional.empty());
 CalendarContainerResource calendarResource = resource.getExportedData();
 Assert.assertEquals(2, calendarResource.getCalendars().size());
 Assert.assertFalse(
   calendarResource
     .getCalendars()
     .stream()
     .anyMatch(c -> "Calendar1".equals(c.getId()) && "Calendar2".equals(c.getId())));
 Assert.assertEquals(2, calendarResource.getEvents().size());
 Assert.assertFalse(
   calendarResource
     .getEvents()
     .stream()
     .anyMatch(
       e ->
         "Test Appointment 1".equals(e.getTitle())
           && "Test Appointment 2".equals(e.getTitle())));
}

代码示例来源:origin: apache/jclouds

public void testDeleteReturns404() throws Exception {
 server.enqueue(response404());
 final VirtualMachineApi vmAPI = api.getVirtualMachineApi("groupname");
 URI uri = vmAPI.delete("windowsmachine");
 assertEquals(server.getRequestCount(), 1);
 assertNull(uri);
 assertSent(server, "DELETE", "/subscriptions/SUBSCRIPTIONID/resourceGroups/groupname/providers/Microsoft.Compute"
    + "/virtualMachines/windowsmachine?api-version=2018-06-01");
}

代码示例来源:origin: apache/jclouds

public void testConnectContainerToNetwork() throws Exception {
 MockWebServer server = mockWebServer(new MockResponse().setResponseCode(200));
 NetworkApi api = api(DockerApi.class, server.getUrl("/").toString()).getNetworkApi();
 try {
   api.connectContainerToNetwork("123456789", "containerName");
   assertSent(server, "POST", "/networks/123456789/connect", "{ \"Container\": \"containerName\" }");
 } finally {
   server.shutdown();
 }
}

代码示例来源:origin: apache/jclouds

@Test
public void testNoRetriesSuccessful() throws Exception {
 MockWebServer server = mockWebServer(new MockResponse());
 IntegrationTestClient client = client(server.getUrl("/").toString());
 try {
   client.download("");
   assertEquals(server.getRequestCount(), 1);
 } finally {
   closeQuietly(client);
   server.shutdown();
 }
}

代码示例来源:origin: apache/jclouds

public void testInstanceReturns404() throws Exception {
 server.enqueue(response404());
 Instance instance = resourceApi().instance(server.getUrl("/foo/bar").toURI());
 assertNull(instance);
 assertSent(server, "GET", "/foo/bar");
}

代码示例来源:origin: org.hobsoft.microbrowser/microbrowser-tck

@Test
public void getLinksWithUnknownRelReturnsEmptyList()
{
  server().enqueue(new MockResponse().setBody("<html><body/></html>"));
  
  List<Link> actual = newBrowser().get(url(server()))
    .getLinks("x");
  
  assertThat("links", actual, is(empty()));
}

代码示例来源:origin: org.hobsoft.microbrowser/microbrowser-tck

@Test
public void getRequestsPath() throws InterruptedException
{
  server().enqueue(new MockResponse());
  
  newBrowser().get(url(server(), "/x"));
  
  assertThat("request path", server().takeRequest().getPath(), is("/x"));
}

代码示例来源:origin: google/data-transfer-project

@After
 public void tearDown() throws Exception {
  server.shutdown();
 }
}

代码示例来源:origin: Coinomi/coinomi-android

@Before
public void setup() throws IOException {
  server = new MockWebServer();
  server.start();
  shapeShift = new ShapeShift();
  shapeShift.baseUrl = server.getUrl("/").toString();
  shapeShift.client.setConnectionSpecs(Collections.singletonList(ConnectionSpec.CLEARTEXT));
}

代码示例来源:origin: apache/jclouds

/**
* Ensures server received authentication request.
*/
public void assertAuthentication(MockWebServer server) {
 assertTrue(server.getRequestCount() >= 1);
 try {
   assertEquals(server.takeRequest().getRequestLine(), "POST /tokens HTTP/1.1");
 } catch (InterruptedException e) {
   Throwables.propagate(e);
 }
}

代码示例来源:origin: appnexus/mobile-sdk-android

private RecordedRequest takeNoAdURLRequestFromQueue(int position){
  RecordedRequest request = null;
  for (int i = 1; i <= position; i++) {
    try {
      request  = server.takeRequest();
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }
  return request;
}

代码示例来源:origin: apache/jclouds

public static MockWebServer mockOpenStackServer() throws IOException {
 MockWebServer server = new MockWebServer();
 server.play();
 URL url = server.getUrl("");
 server.setDispatcher(getURLReplacingQueueDispatcher(url));
 return server;
}

代码示例来源:origin: apache/jclouds

/**
* Creates a {@link MockWebServer} that uses the
* {@link GlobalChecksRequestDispatcher}.
*/
protected static MockWebServer mockWebServer(MockResponse... responses) throws IOException {
 MockWebServer server = new MockWebServer();
 server.play();
 for (MockResponse response : responses) {
   server.enqueue(response);
 }
 return server;
}

代码示例来源:origin: apache/jclouds

@BeforeMethod
public void start() throws IOException {
 tempAuthServer = new MockWebServer();
 tempAuthServer.play();
 swiftServer = new MockWebServer();
 swiftServer.play();
}

代码示例来源:origin: apache/jclouds

static MockWebServer createMockWebServer() throws IOException {
 MockWebServer server = new MockWebServer();
 server.play();
 URL url = server.getUrl("");
 return server;
}

代码示例来源:origin: cfg4j/cfg4j

private void runMockServer() throws IOException {
  server = new MockWebServer();
  server.setDispatcher(dispatcher);
  server.start(0);
 }
}

代码示例来源:origin: cdancy/bitbucket-rest

/**
 * Create a MockWebServer.
 *
 * @return instance of MockWebServer
 * @throws IOException
 *             if unable to start/play server
 */
public static MockWebServer mockWebServer() throws IOException {
  final MockWebServer server = new MockWebServer();
  server.start();
  return server;
}

相关文章