- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 98 for Dispatcher (0.06 seconds)
-
docs/changelogs/changelog_2x.md
* New: `Headers.toMultimap()`. * New: `RequestBody.create(MediaType, ByteString)`. * New: `ConnectionSpec.isCompatible(SSLSocket)`. * New: `Dispatcher.getQueuedCallCount()` and `Dispatcher.getRunningCallCount()`. These can be useful in diagnostics. * Fix: OkHttp no longer shares timeouts between pooled connections. This was causing some applications to crash when connections were reused.
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 26.6K bytes - Click Count (0) -
okhttp/api/android/okhttp.api
public fun connectionAcquired (Lokhttp3/Call;Lokhttp3/Connection;)V public fun connectionReleased (Lokhttp3/Call;Lokhttp3/Connection;)V public fun dispatcherQueueEnd (Lokhttp3/Call;Lokhttp3/Dispatcher;)V public fun dispatcherQueueStart (Lokhttp3/Call;Lokhttp3/Dispatcher;)V public fun dnsEnd (Lokhttp3/Call;Ljava/lang/String;Ljava/util/List;)V public fun dnsStart (Lokhttp3/Call;Ljava/lang/String;)V
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 70.3K bytes - Click Count (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? {Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 6K bytes - Click Count (0) -
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) .isNotNull() .startsWith("canceled due to")Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 18:33:48 GMT 2025 - 6.4K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/Init.java
ListPromptBuilder listPromptBuilder = promptBuilder .createListPrompt() .name("defaultDispatcher") .message("Which dispatcher you want to use as default?"); listPromptBuilder .newItem() .name(NONE) .text("None (disable MavenSecDispatcher)") .add();Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Jun 11 13:14:09 GMT 2025 - 12K bytes - Click Count (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)
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 16:11:23 GMT 2025 - 28.2K bytes - Click Count (0) -
impl/maven-cli/pom.xml
<groupId>org.codehaus.plexus</groupId> <artifactId>plexus-classworlds</artifactId> </dependency> <dependency> <groupId>org.codehaus.plexus</groupId> <artifactId>plexus-sec-dispatcher</artifactId> </dependency> <dependency> <groupId>org.codehaus.plexus</groupId> <artifactId>plexus-xml</artifactId> </dependency> <dependency>
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Nov 18 18:03:26 GMT 2025 - 10.2K bytes - Click Count (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
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 06 14:55:54 GMT 2022 - 50.8K bytes - Click Count (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()
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 18:33:48 GMT 2025 - 9.7K bytes - Click Count (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 {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat May 10 11:15:14 GMT 2025 - 10.9K bytes - Click Count (0)