Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 98 for Dispatcher (0.06 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top