Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for Cancelling (0.07 sec)

  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
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Nov 09 15:47:27 UTC 2023
    - 609 bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/MoreExecutors.java

            return Callables.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.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (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
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (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 {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  6. 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
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  7. 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
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  8. 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
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Fri Oct 14 07:03:14 UTC 2022
    - 367.3K bytes
    - Viewed (0)
  9. okhttp/src/main/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.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  10. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 18 20:44:38 UTC 2022
    - 2.7K bytes
    - Viewed (0)
Back to top