Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for listenablefuture (0.18 sec)

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

      @SafeVarargs
      public static <V extends @Nullable Object> ListenableFuture<List<V>> allAsList(
          ListenableFuture<? extends V>... futures) {
        ListenableFuture<List<@Nullable V>> nullable =
            new ListFuture<V>(ImmutableList.copyOf(futures), true);
        // allAsList ensures that it fills the output list with V instances.
        @SuppressWarnings("nullness")
        ListenableFuture<List<V>> nonNull = nullable;
        return nonNull;
      }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 59.6K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

    /**
     * An abstract implementation of {@link ListenableFuture}, intended for advanced users only. More
     * common ways to create a {@code ListenableFuture} include instantiating a {@link SettableFuture},
     * submitting a task to a {@link ListeningExecutorService}, and deriving a {@code Future} from an
     * existing one, typically using methods like {@link Futures#transform(ListenableFuture,
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 63K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/cache/CacheLoadingTest.java

    import com.google.common.util.concurrent.Callables;
    import com.google.common.util.concurrent.ExecutionError;
    import com.google.common.util.concurrent.Futures;
    import com.google.common.util.concurrent.ListenableFuture;
    import com.google.common.util.concurrent.UncheckedExecutionException;
    import java.io.IOException;
    import java.lang.ref.WeakReference;
    import java.util.List;
    import java.util.Map;
    import java.util.Map.Entry;
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 86.2K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java

    import com.google.common.util.concurrent.Callables;
    import com.google.common.util.concurrent.ExecutionError;
    import com.google.common.util.concurrent.Futures;
    import com.google.common.util.concurrent.ListenableFuture;
    import com.google.common.util.concurrent.UncheckedExecutionException;
    import java.io.IOException;
    import java.lang.ref.WeakReference;
    import java.util.List;
    import java.util.Map;
    import java.util.Map.Entry;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 86.2K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

                      @Override
                      public String call(DeferredCloser closer) throws Exception {
                        return "value";
                      }
                    }),
                executor);
        ListenableFuture<?> statusFuture = closingFuture.statusFuture();
        waiter.awaitStarted();
        assertThat(statusFuture.isDone()).isFalse();
        waiter.awaitReturned();
        assertThat(getUninterruptibly(statusFuture)).isNull();
      }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

                      @Override
                      public String call(DeferredCloser closer) throws Exception {
                        return "value";
                      }
                    }),
                executor);
        ListenableFuture<?> statusFuture = closingFuture.statusFuture();
        waiter.awaitStarted();
        assertThat(statusFuture.isDone()).isFalse();
        waiter.awaitReturned();
        assertThat(getUninterruptibly(statusFuture)).isNull();
      }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 74.7K bytes
    - Viewed (0)
  7. guava/src/com/google/common/cache/CacheBuilder.java

     * AsyncCacheLoader.asyncLoad}</a> must return a {@code CompletableFuture}. Users of Guava's {@link
     * com.google.common.util.concurrent.ListenableFuture} can adapt between the two {@code Future}
     * types by using <a href="https://github.com/lukas-krecan/future-converter#java8-guava">{@code
     * net.javacrumbs.futureconverter.java8guava.FutureConverter}</a>.
     *
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 51.3K bytes
    - Viewed (0)
Back to top