Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 3 of 3 for FutureCombiner (0.07 seconds)

  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(
    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/src/com/google/common/util/concurrent/ClosingFuture.java

                }
              };
          ClosingFuture<V> derived =
              new ClosingFuture<>(futureCombiner().callAsync(asyncCallable, executor));
          derived.state.closeables.add(closeables, directExecutor());
          return derived;
        }
    
        private FutureCombiner<@Nullable Object> futureCombiner() {
          return allMustSucceed
              ? Futures.whenAllSucceed(inputFutures())
    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)
  3. android/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
     */
    @GwtCompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.5K bytes
    - Click Count (0)
Back to Top