Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for canceler (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top