Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for Cancellation (0.09 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 Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

            .that(step3.statusFuture().isCancelled())
            .isTrue();
        // Its closeable is still open.
        assertStillOpen(closeable3);
    
        // Step 4 is not cancelled, because it caught the cancellation.
        assertWithMessage("step4.statusFuture().isCancelled()")
            .that(step4.statusFuture().isCancelled())
            .isFalse();
        // Its closeable isn't closed yet.
        assertStillOpen(closeable4);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 63K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

            .that(step3.statusFuture().isCancelled())
            .isTrue();
        // Its closeable is still open.
        assertStillOpen(closeable3);
    
        // Step 4 is not cancelled, because it caught the cancellation.
        assertWithMessage("step4.statusFuture().isCancelled()")
            .that(step4.statusFuture().isCancelled())
            .isFalse();
        // Its closeable isn't closed yet.
        assertStillOpen(closeable4);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 63K bytes
    - Click Count (0)
  4. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  5. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
Back to Top