Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for cancellation (0.05 seconds)

  1. android/guava/src/com/google/common/util/concurrent/Futures.java

     * Futures#transform(ListenableFuture, Function, Executor) Futures.transform}, but you will often
     * find it easier to use a framework. Frameworks automate the process, often adding features like
     * monitoring, debugging, and cancellation. Examples of frameworks include:
     *
     * <ul>
     *   <li><a href="https://dagger.dev/producers.html">Dagger Producers</a>
     * </ul>
     *
    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)
  2. cmd/bucket-handlers.go

    		output = make([]ObjectToDelete, len(input))
    		idx := 0
    		for obj := range input {
    			output[idx] = obj
    			idx++
    		}
    		return output
    	}
    
    	// Disable timeouts and cancellation
    	ctx = bgContext(ctx)
    
    	deleteList := toNames(objectsToDelete)
    	dObjects, errs := deleteObjectsFn(ctx, bucket, deleteList, ObjectOptions{
    		PrefixEnabledFn:  vc.PrefixEnabled,
    		VersionSuspended: vc.Suspended(),
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

     *
     * <p>A pipeline of {@code ClosingFuture}s is a tree of steps. Each step represents either an
     * asynchronously-computed intermediate value, or else an exception that indicates the failure or
     * cancellation of the operation so far. The only way to extract the value or exception from a step
     * is by declaring that step to be the last step of the pipeline. Nevertheless, we refer to the
    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)
  4. cmd/erasure-server-pool.go

    		defer close(errCh)
    		// Merge all entries from all disks.
    		// We leave quorum at 1, since entries are already resolved to have the desired quorum.
    		// mergeEntryChannels will close 'merged' channel upon completion or cancellation.
    		errCh <- mergeEntryChannels(ctx, entries, merged, 1)
    	}()
    
    	return nil
    }
    
    // HealObjectFn closure function heals the object.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
Back to Top