- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 270 for enqueue (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/jvmTest/kotlin/okhttp3/CacheCorruptionTest.kt
server.useHttps(handshakeCertificates.sslSocketFactory()) server.enqueue( MockResponse( headers = headersOf( "Last-Modified", formatDate(-1, TimeUnit.HOURS)!!, "Expires", formatDate(1, TimeUnit.HOURS)!!, ), body = "ABC.1", ), ) server.enqueue( MockResponse( headers = headersOf(
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Jun 18 12:28:21 GMT 2025 - 6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt
} server.useHttps(serverSslSocketFactory) } else if (socketMode == Channel) { socketFactory(ChannelSocketFactory()) } }.build() server.enqueue(MockResponse(body = "abc")) @Suppress("HttpUrlsUsage") val url = if (socketMode is TlsInstance) { "https://$hostname:${server.port}/get" } else {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 7.9K bytes - Click Count (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/QueueDispatcher.kt
override fun peek(): MockResponse = throw UnsupportedOperationException("unexpected call") fun enqueueResponse(response: MockResponse) { delegate.enqueue(response.wrap()) } override fun shutdown() { delegate.close() } fun setFailFast(failFast: Boolean) { delegate.setFailFast(failFast) }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Jun 14 16:09:26 GMT 2025 - 1.3K bytes - Click Count (0) -
okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt
import okio.IOException suspend fun Call.executeAsync(): Response = suspendCancellableCoroutine { continuation -> continuation.invokeOnCancellation { this.cancel() } this.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { continuation.resumeWithException(e) } override fun onResponse(
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jun 19 04:20:30 GMT 2025 - 1.4K bytes - Click Count (1) -
okhttp/src/jvmTest/kotlin/okhttp3/InterceptorOverridesTest.kt
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 11 02:37:00 GMT 2026 - 28.8K bytes - Click Count (0) -
native-image-tests/src/test/kotlin/okhttp3/nativeimage/SampleTest.kt
private val client = OkHttpClient() @Test fun passingTest() { assertThat("hello").isEqualTo("hello") } @Test fun testMockWebServer() { server.enqueue(MockResponse(body = "abc")) server.start() client.newCall(Request(url = server.url("/"))).execute().use { assertThat(it.body.string()).isEqualTo("abc") } } @Test
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jul 22 20:31:49 GMT 2025 - 1.4K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/HttpsServer.java
.heldCertificate(localhostCertificate) .build(); MockWebServer server = new MockWebServer(); server.useHttps(serverCertificates.sslSocketFactory(), false); server.enqueue(new MockResponse()); HandshakeCertificates clientCertificates = new HandshakeCertificates.Builder() .addTrustedCertificate(localhostCertificate.certificate()) .build();
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jan 02 14:04:37 GMT 2023 - 2.1K bytes - Click Count (0) -
module-tests/src/test/java/okhttp3/modules/test/JavaModuleTest.java
OkHttpCaller.callOkHttp(HttpUrl.get("https://square.com/robots.txt")); } @Test public void testMockWebServer() throws IOException { MockWebServer server = new MockWebServer(); server.enqueue(new MockResponse(200, Headers.of(), "Hello, Java9!")); server.start(); // Just check we can run code that depends on OkHttp types Call call = OkHttpCaller.callOkHttp(server.url("/"));
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Sep 21 06:22:22 GMT 2025 - 2.1K bytes - Click Count (0) -
samples/compare/src/test/kotlin/okhttp3/compare/JettyHttpClientTest.kt
@StartStop private val server = MockWebServer() @BeforeEach fun setUp() { client.start() } @AfterEach fun tearDown() { client.stop() } @Test fun get() { server.enqueue(MockResponse(body = "hello, Jetty HTTP Client")) val request = client .newRequest(server.url("/").toUri()) .header("Accept", "text/plain") val response = request.send()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Jun 18 12:28:21 GMT 2025 - 2.1K bytes - Click Count (0) -
samples/compare/src/test/kotlin/okhttp3/compare/JavaHttpClientTest.kt
@Test fun get() { // Not available platform.expectFailureOnJdkVersion(8) val httpClient = HttpClient .newBuilder() .followRedirects(NORMAL) .build() server.enqueue( MockResponse .Builder() .body("hello, Java HTTP Client") .build(), ) val request = HttpRequest .newBuilder(server.url("/").toUri())
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 25 13:16:02 GMT 2026 - 2.6K bytes - Click Count (0)