Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 57 for ListenableFuture (0.31 sec)

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

     * ListenableFuture}</a>.
     *
     * <p>This class is GWT-compatible.
     *
     * <h3>Purpose</h3>
     *
     * <p>The main purpose of {@code ListenableFuture} is to help you chain together a graph of
     * asynchronous operations. You can chain them together manually with calls to methods like {@link
     * Futures#transform(ListenableFuture, com.google.common.base.Function, Executor) Futures.transform}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  2. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     * ListenableFuture}</a>.
     *
     * <p>This class is GWT-compatible.
     *
     * <h3>Purpose</h3>
     *
     * <p>The main purpose of {@code ListenableFuture} is to help you chain together a graph of
     * asynchronous operations. You can chain them together manually with calls to methods like {@link
     * Futures#transform(ListenableFuture, com.google.common.base.Function, Executor) Futures.transform}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/ListenableFuture.java

     * ListenableFuture}</a>.
     *
     * <p>This class is GWT-compatible.
     *
     * <h3>Purpose</h3>
     *
     * <p>The main purpose of {@code ListenableFuture} is to help you chain together a graph of
     * asynchronous operations. You can chain them together manually with calls to methods like {@link
     * Futures#transform(ListenableFuture, com.google.common.base.Function, Executor) Futures.transform}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  4. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 12 21:42:09 UTC 2018
    - 2.2K bytes
    - Viewed (0)
  5. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java

       */
    
      public static <V extends @Nullable Object> ListenableFuture<V> catching(
          ListenableFuture<? extends V> input,
          Class<Throwable> exceptionType,
          Function<? super Throwable, ? extends V> fallback,
          Executor executor) {
        return AbstractCatchingFuture.create(input, exceptionType, fallback, executor);
      }
    
      public static <V extends @Nullable Object> ListenableFuture<V> catchingAsync(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 24 17:45:05 UTC 2024
    - 2K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java

     * @author Nishant Thakkar
     * @since 10.0
     */
    @GwtIncompatible
    public class MockFutureListener implements Runnable {
      private final CountDownLatch countDownLatch;
      private final ListenableFuture<?> future;
    
      public MockFutureListener(ListenableFuture<?> future) {
        this.countDownLatch = new CountDownLatch(1);
        this.future = future;
    
        future.addListener(this, directExecutor());
      }
    
      @Override
      public void run() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:12:42 UTC 2023
    - 3K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ListeningExecutorService.java

    public interface ListeningExecutorService extends ExecutorService {
      /**
       * @return a {@code ListenableFuture} representing pending completion of the task
       * @throws RejectedExecutionException {@inheritDoc}
       */
      @Override
      <T extends @Nullable Object> ListenableFuture<T> submit(Callable<T> task);
    
      /**
       * @return a {@code ListenableFuture} representing pending completion of the task
       * @throws RejectedExecutionException {@inheritDoc}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sun Jun 20 10:45:35 UTC 2021
    - 4.2K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTest.java

    /** Test for {@link ListenableFuture}. */
    public class ListenableFutureTest extends TestCase {
      public void testNoNewApis() throws Exception {
        assertWithMessage(
                "Do not add new methods to ListenableFuture. Its API needs to continue to match the"
                    + " version we released in a separate artifact com.google.guava:listenablefuture.")
            .that(ListenableFuture.class.getDeclaredMethods())
            .asList()
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Jun 15 19:48:16 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

          Future<V> future) {
        if (future instanceof ListenableFuture) {
          return (ListenableFuture<V>) future;
        }
        return new ListenableFutureAdapter<>(future);
      }
    
      /**
       * Submits a blocking task for the given {@link Future} to provide {@link ListenableFuture}
       * functionality.
       *
       * <p><b>Warning:</b> If the input future does not already implement {@code ListenableFuture}, the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

          Future<V> future) {
        if (future instanceof ListenableFuture) {
          return (ListenableFuture<V>) future;
        }
        return new ListenableFutureAdapter<>(future);
      }
    
      /**
       * Submits a blocking task for the given {@link Future} to provide {@link ListenableFuture}
       * functionality.
       *
       * <p><b>Warning:</b> If the input future does not already implement {@code ListenableFuture}, the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
Back to top