- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 80 for Dispatcher (0.05 sec)
-
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 Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/Main.kt
} return builder.build() } fun close() { val okHttpClient = client as OkHttpClient okHttpClient.connectionPool.evictAll() // Close any persistent connections. okHttpClient.dispatcher.executorService.shutdownNow() } companion object { internal const val NAME = "okcurl" internal const val DEFAULT_TIMEOUT = -1 private fun versionString(): String? {Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6K 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) } @Test fun successfulCallEventSequence() { server.enqueue(MockResponse(body = "abc")) val call = client.newCall( Request .Builder()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 18:33:48 UTC 2025 - 9.7K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
.url("/b") .toUrl() .openConnection() .getInputStream() // Should succeed. } @Test fun clearDispatcherQueue() { server.enqueue(MockResponse(body = "A")) (server.dispatcher as QueueDispatcher).clear() server.enqueue(MockResponse(body = "B")) val inputStream = server .url("/a") .toUrl() .openConnection() .getInputStream()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Aug 03 22:38:00 UTC 2025 - 28K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
if (windowSize != DEFAULT_INITIAL_WINDOW_SIZE) { writer.windowUpdate(0, (windowSize - DEFAULT_INITIAL_WINDOW_SIZE).toLong()) } } // Thread doesn't use client Dispatcher, since it is scoped potentially across clients via // ConnectionPool. taskRunner.newQueue().execute(name = connectionName, block = readerRunnable) }
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 31.8K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 29.9K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
connection.setReadTimeout(500) try { connection.getResponseCode() fail<Any>() } catch (expected: SocketTimeoutException) { } // Shutting down the server should unblock the dispatcher. server.shutdown() } @Test fun requestUrlReconstructed() { server.enqueue(MockResponse().setBody("hello world")) val url = server.url("/a/deep/path?key=foo%20bar").toUrl()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Jul 03 13:16:34 UTC 2025 - 22.3K 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 Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Dec 30 23:28:56 UTC 2024 - 127.9K bytes - Viewed (1) -
docs/recipes.md
=== ":material-language-kotlin: Kotlin" ```kotlin
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Aug 30 17:01:12 UTC 2025 - 47.8K bytes - Viewed (0) -
CHANGELOG.md
compressed file (like a JAR or APK), so compressing its internal data was redundant. * Fix: Call `ProxySelector.connectFailed()` when a connection's initial TCP handshake fails. * Fix: Change the signature of `Dispatcher` to accept a nullable `ExecutorService`. Changing this parameter to be non-null was an unintended signature change in OkHttp 4.0.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 05 16:02:59 UTC 2025 - 36.2K bytes - Viewed (2)