Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for callAsync (0.07 sec)

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

         */
        public <V extends @Nullable Object> ClosingFuture<V> callAsync(
            AsyncCombiningCallable<V> combiningCallable, Executor executor) {
          AsyncCallable<V> asyncCallable =
              new AsyncCallable<V>() {
                @Override
                public ListenableFuture<V> call() throws Exception {
                  return new Peeker(inputs).callAsync(combiningCallable, closeables);
                }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 97.8K bytes
    - Viewed (0)
  2. 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))
                .callAsync(
                    new AsyncCombiningCallable<TestCloseable>() {
                      @Override
                      public ClosingFuture<TestCloseable> call(DeferredCloser closer, Peeker peeker)
    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. guava/src/com/google/common/util/concurrent/ClosingFuture.java

         */
        public <V extends @Nullable Object> ClosingFuture<V> callAsync(
            AsyncCombiningCallable<V> combiningCallable, Executor executor) {
          AsyncCallable<V> asyncCallable =
              new AsyncCallable<V>() {
                @Override
                public ListenableFuture<V> call() throws Exception {
                  return new Peeker(inputs).callAsync(combiningCallable, closeables);
                }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 98.1K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Futures.java

         *     href="https://errorprone.info/bugpattern/FutureReturnValueIgnored">https://errorprone.info/bugpattern/FutureReturnValueIgnored</a>.
         */
        public <C extends @Nullable Object> ListenableFuture<C> callAsync(
            AsyncCallable<C> combiner, Executor executor) {
          return new CombinedFuture<>(futures, allMustSucceed, executor, combiner);
        }
    
        /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
Back to top