本文整理了Java中com.squareup.okhttp.mockwebserver.MockWebServer
类的一些代码示例,展示了MockWebServer
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MockWebServer
类的具体详情如下:
包路径:com.squareup.okhttp.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;
}
内容来源于网络,如有侵权,请联系作者删除!