Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for FutureCombiner (0.06 sec)

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

      }
    
      /**
       * Creates a {@link FutureCombiner} that processes the completed futures whether or not they're
       * successful.
       *
       * <p>Any failures from the input futures will not be propagated to the returned future.
       *
       * @since 20.0
       */
      public static <V extends @Nullable Object> FutureCombiner<V> whenAllComplete(
    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. guava/src/com/google/common/util/concurrent/AsyncCallable.java

    import java.util.concurrent.Future;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Computes a value, possibly asynchronously. For an example usage and more information, see {@link
     * Futures.FutureCombiner#callAsync(AsyncCallable, java.util.concurrent.Executor)}.
     *
     * <p>Much like {@link java.util.concurrent.Callable}, but returning a {@link ListenableFuture}
     * result.
     *
     * @since 20.0
     */
    @FunctionalInterface
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

                }
              };
          ClosingFuture<V> derived =
              new ClosingFuture<>(futureCombiner().callAsync(asyncCallable, executor));
          derived.closeables.add(closeables, directExecutor());
          return derived;
        }
    
        private FutureCombiner<@Nullable Object> futureCombiner() {
          return allMustSucceed
              ? Futures.whenAllSucceed(inputFutures())
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 97.8K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/ClosingFuture.java

                }
              };
          ClosingFuture<V> derived =
              new ClosingFuture<>(futureCombiner().callAsync(asyncCallable, executor));
          derived.closeables.add(closeables, directExecutor());
          return derived;
        }
    
        private FutureCombiner<@Nullable Object> futureCombiner() {
          return allMustSucceed
              ? Futures.whenAllSucceed(inputFutures())
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 98.1K bytes
    - Viewed (0)
Back to top