- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for executorService (0.05 sec)
-
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) -
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)