Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 25 for Cancelling (0.07 seconds)

  1. okhttp-coroutines/README.md

    but uses the standard Dispatcher in OkHttp. This means
    that by default Kotlin's Dispatchers are not used.
    
    Cancellation if implemented sensibly in both directions.
    Cancelling a coroutine scope, will cancel the call.
    Cancelling a call, will throw a CancellationException
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Nov 09 15:47:27 GMT 2023
    - 609 bytes
    - Click Count (0)
  2. guava/src/com/google/common/util/concurrent/MoreExecutors.java

            return threadRenaming(command, nameSupplier);
          }
        };
      }
    
      /**
       * Shuts down the given executor service gradually, first disabling new submissions and later, if
       * necessary, cancelling remaining tasks.
       *
       * <p>The method takes the following steps:
       *
       * <ol>
       *   <li>calls {@link ExecutorService#shutdown()}, disabling acceptance of new submitted tasks.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 45.2K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/Futures.java

              },
              executor);
        }
      }
    
      /**
       * Returns a {@code ListenableFuture} whose result is set from the supplied future when it
       * completes. Cancelling the supplied future will also cancel the returned future, but cancelling
       * the returned future will have no effect on the supplied future.
       *
       * @since 15.0
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 64.3K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

     * #whenAllComplete(Iterable)} or {@link #whenAllSucceed(Iterable)} or its overloads.
     *
     * <h3>Cancelling</h3>
     *
     * Any step in a pipeline can be {@linkplain #cancel(boolean) cancelled}, even after another step
     * has been derived, with the same semantics as cancelling a {@link Future}. In addition, a
     * successfully cancelled step will immediately start closing all objects captured for later closing
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 13:51:27 GMT 2025
    - 96.9K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

        }
      }
    
      private void processAllMustSucceedDoneFuture(
          int index, ListenableFuture<? extends InputT> future) {
        try {
          if (future.isCancelled()) {
            // Clear futures prior to cancelling children. This sets our own state but lets
            // the input futures keep running, as some of them may be used elsewhere.
            futures = null;
            cancel(false);
          } else {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 16K bytes
    - Click Count (0)
  6. chainable_api.go

    //
    // Offset conditions can be cancelled by using `Offset(-1)`.
    //
    //	// select the third user
    //	db.Offset(2).First(&user)
    //	// select the first user by cancelling an earlier chained offset
    //	db.Offset(5).Offset(-1).First(&user)
    func (db *DB) Offset(offset int) (tx *DB) {
    	tx = db.getInstance()
    	tx.Statement.AddClause(clause.Limit{Offset: offset})
    	return
    }
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Sep 19 01:49:06 GMT 2025
    - 14.8K bytes
    - Click Count (0)
  7. CHANGELOG/CHANGELOG-1.21.md

    - When the kubelet is watching a ConfigMap or Secret purely in the context of setting environment variables
      for containers, only hold that watch for a defined duration before cancelling it. This change reduces the CPU
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Fri Oct 14 07:03:14 GMT 2022
    - 367.3K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

     * will prefer pooled connections. Only pooled HTTP/2 connections are used for such de-duplication.
     *
     * It is possible to cancel the finding process by canceling its call.
     *
     * Implementations of this interface are not thread-safe. Each instance is thread-confined to the
     * thread executing the call.
     */
    interface RoutePlanner {
      val address: Address
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue May 27 14:58:02 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  9. internal/dsync/locker.go

    	// Canceling the context will abort the remote call.
    	// In that case, the resource may or may not be unlocked.
    	RUnlock(ctx context.Context, args LockArgs) (bool, error)
    
    	// Do write unlock for given LockArgs. It should return
    	// * a boolean to indicate success/failure of the operation
    	// * an error on failure of unlock request operation.
    	// Canceling the context will abort the remote call.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jan 18 20:44:38 GMT 2022
    - 2.7K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Task.kt

     *
     * Cancellation
     * ------------
     *
     * Tasks may be canceled while they are waiting to be executed, or while they are executing.
     *
     * Canceling a task that is waiting to execute prevents that upcoming execution. Canceling a task
     * that is currently executing does not impact the ongoing run, but it does prevent a recurrence
     * from being scheduled.
     *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 2.4K bytes
    - Click Count (0)
Back to Top