Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 8 of 8 for FutureCallback (0.09 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

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

     * asynchronously.
     *
     * <p>To attach to a {@link ListenableFuture} use {@link Futures#addCallback}.
     *
     * @author Anthony Zana
     * @since 10.0
     */
    @GwtCompatible
    public interface FutureCallback<V extends @Nullable Object> {
      /** Invoked with the result of the {@code Future} computation when it is successful. */
      void onSuccess(@ParametricNullness V result);
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java

        addCallback(f, callback, directExecutor());
        f.setException(e);
      }
    
      public void testCancel() {
        SettableFuture<String> f = SettableFuture.create();
        FutureCallback<String> callback =
            new FutureCallback<String>() {
              private final Object monitor = new Object();
              private boolean called = false;
    
              @Override
              public void onSuccess(String result) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 15:59:55 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java

        addCallback(f, callback, directExecutor());
        f.setException(e);
      }
    
      public void testCancel() {
        SettableFuture<String> f = SettableFuture.create();
        FutureCallback<String> callback =
            new FutureCallback<String>() {
              private final Object monitor = new Object();
              private boolean called = false;
    
              @Override
              public void onSuccess(String result) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 15:59:55 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  4. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/ListenableFuture.java

        return new Promise<V>(
                (resolve, reject) -> {
                  Futures.addCallback(
                      this,
                      new FutureCallback<V>() {
                        @Override
                        public void onSuccess(V value) {
                          resolve.onInvoke(value);
                        }
    
                        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 3.8K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

      }
    
      public void testAddCallback() {
        FluentFuture<String> f = FluentFuture.from(immediateFuture("a"));
        boolean[] called = new boolean[1];
        f.addCallback(
            new FutureCallback<String>() {
              @Override
              public void onSuccess(String result) {
                called[0] = true;
              }
    
              @Override
              public void onFailure(Throwable t) {}
            },
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       * callbacks, but any callback added through this method is guaranteed to be called once the
       * computation is complete.
       *
       * <p>Example:
       *
       * {@snippet :
       * future.addCallback(
       *     new FutureCallback<QueryResult>() {
       *       public void onSuccess(QueryResult result) {
       *         storeInCache(result);
       *       }
       *       public void onFailure(Throwable t) {
       *         reportError(t);
       *       }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 19.8K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/Futures.java

      public static <V extends @Nullable Object> void addCallback(
          ListenableFuture<V> future, FutureCallback<? super V> callback, Executor executor) {
        Preconditions.checkNotNull(callback);
        future.addListener(new CallbackListener<V>(future, callback), executor);
      }
    
      /** See {@link #addCallback(ListenableFuture, FutureCallback, Executor)} for behavioral notes. */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

        checkNotNull(closingExecutor);
        ClosingFuture<C> closingFuture = new ClosingFuture<>(nonCancellationPropagating(future));
        Futures.addCallback(
            future,
            new FutureCallback<@Nullable AutoCloseable>() {
              @Override
              public void onSuccess(@Nullable AutoCloseable result) {
                closingFuture.state.closeables.closer.eventuallyClose(result, closingExecutor);
              }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 101.7K bytes
    - Click Count (0)
Back to Top