Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 104 for ListenableFuture (0.28 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. guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java

      private static final String DATA1 = "data";
    
      public void testListenInPoolThreadReturnsSameFuture() throws Exception {
        ListenableFuture<String> listenableFuture = immediateFuture(DATA1);
        assertSame(listenableFuture, listenInPoolThread(listenableFuture));
      }
    
      private static class SingleCallListener implements Runnable {
    
        private boolean expectCall = false;
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 9.7K bytes
    - Viewed (0)
  5. futures/listenablefuture9999/pom.xml

        - 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)
  6. 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 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  7. 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);
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java

     *
     * <h3>Extension</h3>
     *
     * If you want a class like {@code FluentFuture} but with extra methods, we recommend declaring your
     * own subclass of {@link ListenableFuture}, complete with a method like {@link #from} to adapt an
     * existing {@code ListenableFuture}, implemented atop a {@link ForwardingListenableFuture} that
     * forwards to that future and adds the desired methods.
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed May 05 22:27:35 GMT 2021
    - 2.5K bytes
    - Viewed (0)
  9. 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}.
       */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 11 19:08:44 GMT 2023
    - 18.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/SettableFuture.java

    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * A {@link ListenableFuture} whose result can be set by a {@link #set(Object)}, {@link
     * #setException(Throwable)} or {@link #setFuture(ListenableFuture)} call. It can also, like any
     * other {@code Future}, be {@linkplain #cancel cancelled}.
     *
     * <p>{@code SettableFuture} is the recommended {@code ListenableFuture} implementation when your
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Oct 01 17:18:04 GMT 2021
    - 2.4K bytes
    - Viewed (0)
Back to top