Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 111 for dispatcher (0.07 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Dec 30 23:28:56 UTC 2024
    - 127.9K bytes
    - Viewed (0)
  9. 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)
  10. 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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 14:12:28 UTC 2025
    - 29K bytes
    - Viewed (0)
Back to top