Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for cancellation (0.09 sec)

  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>
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  2. 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);
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 75.4K bytes
    - Viewed (0)
  3. cmd/bucket-handlers.go

    		output = make([]ObjectToDelete, len(input))
    		idx := 0
    		for obj := range input {
    			output[idx] = obj
    			idx++
    		}
    		return
    	}
    
    	// Disable timeouts and cancellation
    	ctx = bgContext(ctx)
    
    	deleteList := toNames(objectsToDelete)
    	dObjects, errs := deleteObjectsFn(ctx, bucket, deleteList, ObjectOptions{
    		PrefixEnabledFn:  vc.PrefixEnabled,
    		VersionSuspended: vc.Suspended(),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (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.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
Back to top