Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 273 for dcancel (0.18 sec)

  1. misc/chrome/gophertool/popup.js

      var t = box.value;
      if (t == "") {
        return false;
      }
    
      var success = function(url) {
        console.log("matched " + t + " to: " + url)
        box.value = "";
        openURL(url);
        return false;  // cancel form submission
      };
    
      var url = urlForInput(t);
      if (url) {
        return success(url);
      }
    
      console.log("no match for text: " + t)
      return false;
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Sun Oct 21 17:05:21 UTC 2012
    - 1020 bytes
    - Viewed (0)
  2. cmd/bucket-targets.go

    		}
    	}
    
    	// Check if target is a MinIO server and alive
    	hcCtx, cancel := context.WithTimeout(ctx, 3*time.Second)
    	scheme := "http"
    	if tgt.Secure {
    		scheme = "https"
    	}
    	result := <-sys.hcClient.Alive(hcCtx, madmin.AliveOpts{}, madmin.ServerProperties{
    		Endpoint: tgt.Endpoint,
    		Scheme:   scheme,
    	})
    
    	cancel()
    	if result.Error != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/ImmediateFuture.java

                      + listener
                      + " with executor "
                      + executor,
                  e);
        }
      }
    
      @Override
      public boolean cancel(boolean mayInterruptIfRunning) {
        return false;
      }
    
      // TODO(lukes): Consider throwing InterruptedException when appropriate.
      @Override
      @ParametricNullness
      public V get() {
        return value;
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  4. okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt

    import okhttp3.internal.closeQuietly
    import okio.IOException
    
    suspend fun Call.executeAsync(): Response =
      suspendCancellableCoroutine { continuation ->
        continuation.invokeOnCancellation {
          this.cancel()
        }
        this.enqueue(
          object : Callback {
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              continuation.resumeWithException(e)
            }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jun 19 04:20:30 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/FailingCall.kt

      override fun request(): Request = error("unexpected")
    
      override fun execute(): Response = error("unexpected")
    
      override fun enqueue(responseCallback: Callback): Unit = error("unexpected")
    
      override fun cancel(): Unit = error("unexpected")
    
      override fun isExecuted(): Boolean = error("unexpected")
    
      override fun isCanceled(): Boolean = error("unexpected")
    
      override fun timeout(): Timeout = error("unexpected")
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  6. .github/workflows/upgrade-ci-cd.yaml

    on:
      pull_request:
        branches:
          - master
    
    # This ensures that previous jobs for the PR are canceled when the PR is
    # updated.
    concurrency:
      group: ${{ github.workflow }}-${{ github.head_ref }}
      cancel-in-progress: true
    
    permissions:
      contents: read
    
    jobs:
      build:
        name: Go ${{ matrix.go-version }} on ${{ matrix.os }}
        runs-on: ${{ matrix.os }}
        strategy:
          matrix:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 729 bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/ErrorCode.kt

    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.2K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

          // code should be unreachable with correctly implemented Futures.
          // Cancel this future and return.
          // At this point, inputFuture is cancelled and outputFuture doesn't exist, so the value of
          // mayInterruptIfRunning is irrelevant.
          cancel(false);
          return;
        } catch (ExecutionException e) {
          // Set the cause of the exception as this future's exception.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java

        }
    
        /**
         * Cancel notification for a handle
         *
         * @param handle notification handle
         */
        private void cancelNotification(ChangeNotificationHandle handle) {
            CompletableFuture<Void> future = handle.getNotificationFuture();
            if (future != null && !future.isDone()) {
                future.cancel(true);
            }
        }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

        step2Waiter.awaitStarted();
    
        // Everything should still be open.
        assertStillOpen(closeable1, closeable2, closeable3, closeable4);
    
        // Cancel step 3, resume step 2, and pause in step 4.
        assertWithMessage("step3.cancel()").that(step3.cancel(false)).isTrue();
        step2Waiter.awaitReturned();
        step4Waiter.awaitStarted();
    
        // Step 1 is not cancelled because it was done.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 75.4K bytes
    - Viewed (0)
Back to top