- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 199 for canceler (0.07 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt
fun networkInterceptorThrowsRuntimeExceptionAsynchronous() { interceptorThrowsRuntimeExceptionAsynchronous(true) } /** * When an interceptor throws an unexpected exception, asynchronous calls are canceled. The * exception goes to the uncaught exception handler. */ private fun interceptorThrowsRuntimeExceptionAsynchronous(network: Boolean) { val boom = RuntimeException("boom!")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 28.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
override fun callFailed( call: Call, ioe: IOException, ) = logEvent(CallFailed(System.nanoTime(), call, ioe)) override fun canceled(call: Call) = logEvent(Canceled(System.nanoTime(), call)) override fun satisfactionFailure( call: Call, response: Response, ) = logEvent(SatisfactionFailure(System.nanoTime(), call))
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 9.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
internal var activeTask: Task? = null /** Scheduled tasks ordered by [Task.nextExecuteNanoTime]. */ internal val futureTasks = mutableListOf<Task>() /** True if the [activeTask] should be canceled when it completes. */ internal var cancelActiveTask = false /** * Returns a snapshot of tasks currently scheduled for execution. Does not include the
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 7.3K bytes - Viewed (0) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt
logWithTime("callEnd") } override fun callFailed( call: Call, ioe: IOException, ) { logWithTime("callFailed: $ioe") } override fun canceled(call: Call) { logWithTime("canceled") } override fun satisfactionFailure( call: Call, response: Response, ) { logWithTime("satisfactionFailure: $response") } override fun cacheHit(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Apr 01 11:07:32 UTC 2024 - 5.4K bytes - Viewed (0) -
docs/features/connections.md
* Prefer to alternate IP addresses from different address families, (IPv6 / IPv4), starting with IPv6. * Don't start a new attempt until 250 ms after the most recent attempt was started. * Keep whichever TCP connection succeeds first and cancel all the others.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Feb 21 03:33:59 UTC 2022 - 5.4K bytes - Viewed (0) -
docs/features/calls.md
Calls can be canceled from any thread. This will fail the call if it hasn’t yet completed! Code that is writing the request body or reading the response body will suffer an `IOException` when its call is canceled. ## Dispatch
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 3.9K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java
printEvent("callEnd"); } @Override public void callFailed(Call call, IOException ioe) { printEvent("callFailed"); } @Override public void canceled(Call call) { printEvent("canceled"); } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 16 23:20:49 UTC 2020 - 5.3K bytes - Viewed (0) -
CHANGELOG.md
* Fix: Attempt to read the response body even if the server canceled the request. This will cause some calls to return nice error codes like `HTTP/1.1 429 Too Many Requests` instead of transport errors like `SocketException: Connection reset` and `StreamResetException: stream was reset: CANCEL`. * New: Support OSGi metadata. * Upgrade: [Okio 2.9.0][okio_2_9_0]. ```kotlin
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 19:32:33 UTC 2025 - 31.6K bytes - Viewed (1) -
src/test/java/jcifs/internal/smb1/trans/nt/SmbComNtCancelTest.java
constructor.setAccessible(true); SmbComNtCancel cancel = constructor.newInstance(config, testMid); // Then assertNotNull(cancel); assertEquals(testMid, cancel.getMid()); assertTrue(cancel.isCancel()); } } @Nested @DisplayName("Method Behavior Tests")
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 12.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
assertFailed(future, cause); } public void testCanceled() throws Exception { assertThat(future.cancel(false /* mayInterruptIfRunning */)).isTrue(); assertCancelled(future, false); } public void testInterrupted() throws Exception { assertThat(future.cancel(true /* mayInterruptIfRunning */)).isTrue(); assertCancelled(future, true); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 15.4K bytes - Viewed (0)