Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for whenAllComplete (0.72 seconds)

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

       * for APIs like {@link #whenAllComplete whenAllComplete(...)}{@code .}{@link
       * FutureCombiner#call(Callable, Executor) call(...)}, where it is easy to use a new input from
       * the {@code call} implementation but forget to add it to the arguments of {@code
       * whenAllComplete}.
       *
    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. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        ListenableFuture<String> unused;
    
        // Compiles:
        unused = whenAllComplete(futureA, futureB).call(combiner, directExecutor());
    
        // Does not compile:
        // unused = whenAllComplete(futures).call(combiner);
    
        // Workaround for the above:
        unused = whenAllComplete(asList(futures)).call(combiner, directExecutor());
      }
    
      @J2ktIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        ListenableFuture<String> unused;
    
        // Compiles:
        unused = whenAllComplete(futureA, futureB).call(combiner, directExecutor());
    
        // Does not compile:
        // unused = whenAllComplete(futures).call(combiner);
    
        // Workaround for the above:
        unused = whenAllComplete(asList(futures)).call(combiner, directExecutor());
      }
    
      @J2ktIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

       *     the arguments, or if any has already been {@linkplain #finishToFuture() finished}
       */
      public static Combiner whenAllComplete(
          ClosingFuture<?> future1, ClosingFuture<?>... moreFutures) {
        return whenAllComplete(asList(future1, moreFutures));
      }
    
      /**
       * Starts specifying how to combine {@link ClosingFuture}s into a single pipeline, assuming they
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 101.7K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

        AtomicReference<ClosingFuture.Peeker> capturedPeeker = new AtomicReference<>();
        ClosingFuture<TestCloseable> closingFuture =
            ClosingFuture.whenAllComplete(ImmutableList.of(input1, input2Failed))
                .call(
                    (closer, peeker) -> {
                      closer.eventuallyClose(closeable1, closingExecutor);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 63K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

        AtomicReference<ClosingFuture.Peeker> capturedPeeker = new AtomicReference<>();
        ClosingFuture<TestCloseable> closingFuture =
            ClosingFuture.whenAllComplete(ImmutableList.of(input1, input2Failed))
                .call(
                    (closer, peeker) -> {
                      closer.eventuallyClose(closeable1, closingExecutor);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 63K bytes
    - Click Count (0)
Back to Top