- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for canceler (0.11 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
}, ).build() val call = client.newCall(Request(server.url("/a"))) call.enqueue(callback) call.cancel() latch.countDown() callback .await(server.url("/a")) .assertFailure("canceled", "Canceled", "Socket closed", "Socket is closed") } @Test fun cancelAll() { val call = client.newCall(Request(server.url("/")))
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 146.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
boolean cancelled = future.cancel(mayInterruptIfRunning); if (cancelled) { close(); } return cancelled; } private void close() { logger.get().log(FINER, "closing {0}", this); closeables.close(); } private <U extends @Nullable Object> ClosingFuture<U> derive(FluentFuture<U> future) { ClosingFuture<U> derived = new ClosingFuture<>(future);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 97.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ClosingFuture.java
boolean cancelled = future.cancel(mayInterruptIfRunning); if (cancelled) { close(); } return cancelled; } private void close() { logger.get().log(FINER, "closing {0}", this); closeables.close(); } private <U extends @Nullable Object> ClosingFuture<U> derive(FluentFuture<U> future) { ClosingFuture<U> derived = new ClosingFuture<>(future);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 98.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
call.execute() }.also { expected -> assertThat(expected.message).isEqualTo("Canceled") } } @Test fun disconnectBeforeConnect() { server.enqueue( MockResponse(body = "A"), ) val call = client.newCall(newRequest("/")) call.cancel() assertFailsWith<IOException> { call.execute() } } @Test
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 133.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/action/FessLabels.java
public static final String LABELS_crawling_info_delete_all_confirmation = "{labels.crawling_info_delete_all_confirmation}"; /** The key of the message: Cancel */ public static final String LABELS_crawling_info_delete_all_cancel = "{labels.crawling_info_delete_all_cancel}"; /** The key of the message: Thread Dump */
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 05 02:36:47 UTC 2025 - 146.4K bytes - Viewed (0) -
okhttp/src/androidMain/baseline-prof.txt
PLkotlinx/coroutines/JobCancellationException;->fillInStackTrace()Ljava/lang/Throwable; PLkotlinx/coroutines/JobImpl;->getOnCancelComplete$kotlinx_coroutines_core()Z PLkotlinx/coroutines/JobKt;->cancel$default(Lkotlin/coroutines/CoroutineContext;Ljava/util/concurrent/CancellationException;ILjava/lang/Object;)V PLkotlinx/coroutines/JobSupport$Finishing;-><init>(Lkotlinx/coroutines/NodeList;ZLjava/lang/Throwable;)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)