Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 105 for ListenableFuture (0.25 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}
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jun 26 21:13:41 GMT 2023
    - 8K bytes
    - Viewed (0)
  2. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/ListenableFuture.java

    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Java super source for ListenableFuture, implementing a structural thenable via a default method.
     * For restrictions, please refer to the documentation of the then() method.
     */
    @ElementTypesAreNonnullByDefault
    public interface ListenableFuture<V extends @Nullable Object> extends Future<V>, IThenable<V> {
      void addListener(Runnable listener, Executor executor);
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Oct 24 18:27:19 GMT 2023
    - 3.9K bytes
    - Viewed (1)
  3. 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}
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jun 26 21:13:41 GMT 2023
    - 8K bytes
    - Viewed (0)
  4. 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
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Dec 14 20:35:03 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java

       * #setFuture(ListenableFuture)}.
       */
      private static final class AsyncCatchingFuture<V extends @Nullable Object, X extends Throwable>
          extends AbstractCatchingFuture<
              V, X, AsyncFunction<? super X, ? extends V>, ListenableFuture<? extends V>> {
        AsyncCatchingFuture(
            ListenableFuture<? extends V> input,
            Class<X> exceptionType,
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 8.7K bytes
    - Viewed (0)
  6. 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;
        }
      }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 16.8K 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;
        }
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 16.8K bytes
    - Viewed (0)
  8. 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
    XML
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 12 21:42:09 GMT 2018
    - 2.2K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ForwardingListenableFuture.java

       * already constructed {@link ListenableFuture} as the delegate.
       *
       * @since 9.0
       */
      public abstract static class SimpleForwardingListenableFuture<V extends @Nullable Object>
          extends ForwardingListenableFuture<V> {
        private final ListenableFuture<V> delegate;
    
        protected SimpleForwardingListenableFuture(ListenableFuture<V> delegate) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Mar 04 12:23:41 GMT 2022
    - 2.4K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

      private interface Merger {
    
        ListenableFuture<List<String>> merged(ListenableFuture<String> a, ListenableFuture<String> b);
    
        Merger allMerger =
            new Merger() {
              @Override
              public ListenableFuture<List<String>> merged(
                  ListenableFuture<String> a, ListenableFuture<String> b) {
                return allAsList(ImmutableSet.of(a, b));
              }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
Back to top