Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for executorService (0.05 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

        /**
         * Attempt to enqueue this async call on [executorService]. This will attempt to clean up
         * if the executor has been shut down by reporting the call as failed.
         */
        fun executeOn(executorService: ExecutorService) {
          client.dispatcher.assertLockNotHeld()
    
          var success = false
          try {
            executorService.execute(this)
            success = true
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  2. 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")
        assertThat(exception).isInstanceOf<IOException>()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 6.1K bytes
    - Viewed (0)
Back to top