Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 47 for ListenableFuture (0.08 sec)

  1. futures/listenablefuture1/pom.xml

        - If users want only ListenableFuture, they depend on listenablefuture-1.0.
    
        - If users want all of Guava, they depend on guava, which, as of Guava
        27.0, depends on
        listenablefuture-9999.0-empty-to-avoid-conflict-with-guava. The 9999.0-...
        version number is enough for some build systems (notably, Gradle) to select
        that empty artifact over the "real" listenablefuture-1.0 -- avoiding a
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Oct 02 19:27:26 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

      }
    
      FluentFuture() {}
    
      /**
       * Converts the given {@code ListenableFuture} to an equivalent {@code FluentFuture}.
       *
       * <p>If the given {@code ListenableFuture} is already a {@code FluentFuture}, it is returned
       * directly. If not, it is wrapped in a {@code FluentFuture} that delegates all calls to the
       * original {@code ListenableFuture}.
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        return delegate.awaitTermination(timeout, unit);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Callable<T> task) {
        Preconditions.checkNotNull(task, "task must not be null!");
        return delegate.submit(task);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Runnable task, T result) {
        Preconditions.checkNotNull(task, "task must not be null!");
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        return delegate.awaitTermination(timeout, unit);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Callable<T> task) {
        Preconditions.checkNotNull(task, "task must not be null!");
        return delegate.submit(task);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Runnable task, T result) {
        Preconditions.checkNotNull(task, "task must not be null!");
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

              public Class<?> loadClass(String name) throws ClassNotFoundException {
                if (name.startsWith(concurrentPackage)
                    // Use other classloader for ListenableFuture, so that the objects can interact
                    && !ListenableFuture.class.getName().equals(name)) {
                  synchronized (loadedClasses) {
                    Class<?> toReturn = loadedClasses.get(name);
                    if (toReturn == null) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  6. 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;
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

      private static final class TestCallable implements AsyncCallable<@Nullable Void> {
    
        private final ListenableFuture<@Nullable Void> future;
        private boolean called = false;
    
        private TestCallable(ListenableFuture<@Nullable Void> future) {
          this.future = future;
        }
    
        @Override
        public ListenableFuture<@Nullable Void> call() throws Exception {
          called = true;
          return future;
        }
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      private CountDownLatch funcIsWaitingLatch;
      // Signals the function so it will complete
      private CountDownLatch funcCompletionLatch;
    
      @Override
      protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) {
        outputFuture = SettableFuture.create();
        funcIsWaitingLatch = new CountDownLatch(1);
        funcCompletionLatch = new CountDownLatch(1);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      private CountDownLatch funcIsWaitingLatch;
      // Signals the function so it will complete
      private CountDownLatch funcCompletionLatch;
    
      @Override
      protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) {
        outputFuture = SettableFuture.create();
        funcIsWaitingLatch = new CountDownLatch(1);
        funcCompletionLatch = new CountDownLatch(1);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

       *   <li>Return a {@code ClosingFuture}. To turn a {@link ListenableFuture} into a {@code
       *       ClosingFuture} call {@link #from(ListenableFuture)}.
       *   <li>In case this step doesn't create new closeables, you can adapt an API that returns a
       *       {@link ListenableFuture} to return a {@code ClosingFuture} by wrapping it with a call to
       *       {@link #withoutCloser(AsyncFunction)}
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 13:51:27 UTC 2025
    - 96.9K bytes
    - Viewed (0)
Back to top