Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 80 for Dispatcher (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

        try {
          InetAddress.getByName("www.google.com")
        } catch (uhe: UnknownHostException) {
          throw TestAbortedException(uhe.message, uhe)
        }
      }
    
      fun OkHttpClient.close() {
        dispatcher.executorService.shutdown()
        connectionPool.evictAll()
      }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 29.9K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top