- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 25 for Cancelling (0.07 seconds)
-
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) -
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) -
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) -
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 closingCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 11 13:51:27 GMT 2025 - 96.9K bytes - Click Count (0) -
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) -
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) -
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) -
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: AddressCreated: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue May 27 14:58:02 GMT 2025 - 4.2K bytes - Click Count (0) -
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) -
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)