- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 111 for dispatcher (0.07 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt
call: Call, response: Response, ) { } }, ) // This should fail the Call, but not cause an unhandled Exception bubbling up client.dispatcher.executorService.shutdownNow() val exception = callFailure.get(5, TimeUnit.SECONDS) assertThat(exception.message).isEqualTo("canceled due to java.lang.InterruptedException")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 6.1K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
// Enqueue a request that'll cause MockWebServer to hang on QueueDispatcher.dispatch(). val connection = server.url("/").toUrl().openConnection() as HttpURLConnection connection.readTimeout = 500 assertFailsWith<SocketTimeoutException> { connection.responseCode } // Closing the server should unblock the dispatcher. server.close() } @Test fun requestUrlReconstructed() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Aug 03 22:38:00 UTC 2025 - 28K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
* Fix: Don't crash when building `HandshakeCertificates` on Android API 28. * Fix: Permit multipart file names to contain non-ASCII characters. * New: API to get MockWebServer's dispatcher. * New: API to access headers as `java.time.Instant`. * New: Fail fast if a `SSLSocketFactory` is used as a `SocketFactory`. * New: Log the TLS handshake in `LoggingEventListener`. ## Version 3.12.13
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt
addInterceptor(network) { chain: Interceptor.Chain? -> throw boom } val executor = ExceptionCatchingExecutor() client = client .newBuilder() .dispatcher(Dispatcher(executor)) .build() val request = Request .Builder() .url(server.url("/")) .build() val call = client.newCall(request) call.enqueue(callback)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 28.2K bytes - Viewed (0) -
okhttp/api/android/okhttp.api
public final fun connectionPool ()Lokhttp3/ConnectionPool; public final fun connectionSpecs ()Ljava/util/List; public final fun cookieJar ()Lokhttp3/CookieJar; public final fun dispatcher ()Lokhttp3/Dispatcher; public final fun dns ()Lokhttp3/Dns; public final fun eventListenerFactory ()Lokhttp3/EventListener$Factory; public final fun fastFallback ()Z public final fun followRedirects ()Z
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 16 09:39:51 UTC 2025 - 69.4K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
sendTestRequest(twitterRequest) Thread.sleep(1000) sendTestRequest(googleRequest) Thread.sleep(2000) } } finally { client.connectionPool.evictAll() client.dispatcher.executorService.shutdownNow() if (launch == CommandLine) { process?.destroyForcibly() } } } private fun sendTestRequest(request: Request) { try {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat May 10 11:15:14 UTC 2025 - 10.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt
.build() @BeforeEach fun setUp() { platform.assumeNotOpenJSSE() platform.assumeNotBouncyCastle() listener.forbidLock(get(client.connectionPool)) listener.forbidLock(client.dispatcher) } @ParameterizedTest @ValueSource(booleans = [true, false]) fun successfulCallEventSequence() { server!!.enqueue(MockResponse(body = "abc")) val call = client.newCall( Request
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 9.8K bytes - Viewed (0) -
okhttp/src/androidMain/baseline-prof.txt
HSPLokhttp3/CookieJar$Companion$NoCookies;->loadForRequest(Lokhttp3/HttpUrl;)Ljava/util/List; HSPLokhttp3/CookieJar;-><clinit>()V HSPLokhttp3/Dispatcher;-><init>()V HSPLokhttp3/Dispatcher;->finished$okhttp(Lokhttp3/internal/connection/RealCall$AsyncCall;)V HSPLokhttp3/Dispatcher;->finished(Ljava/util/Deque;Ljava/lang/Object;)V HSPLokhttp3/Dispatcher;->promoteAndExecute()Z HSPLokhttp3/Dns$Companion$DnsSystem;-><init>()V
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Dec 30 23:28:56 UTC 2024 - 127.9K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
val connection = server.url("/").toUrl().openConnection() as HttpURLConnection connection.setReadTimeout(500) try { connection.getResponseCode() fail<Any>() } catch (expected: SocketTimeoutException) { } // Shutting down the server should unblock the dispatcher. server.shutdown() } @Test
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 03 13:16:34 UTC 2025 - 22.3K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 02 14:12:28 UTC 2025 - 29K bytes - Viewed (0)