Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 28 of 28 for ImmediateFuture (0.06 seconds)

  2. github.com/google/guava

    android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java 

    import static com.google.common.util.concurrent.ExecutionSequencer.RunningState.STARTED;
import static com.google.common.util.concurrent.Futures.immediateCancelledFuture;
import static com.google.common.util.concurrent.Futures.immediateFuture;
import static com.google.common.util.concurrent.Futures.immediateVoidFuture;
import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
import static java.util.Objects.requireNonNull;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 22.1K bytes
    - Click Count (0)
  3. github.com/google/guava

    guava-tests/test/com/google/common/cache/CacheLoadingTest.java 

    import static com.google.common.truth.Truth.assertWithMessage;
import static com.google.common.util.concurrent.Futures.immediateFailedFuture;
import static com.google.common.util.concurrent.Futures.immediateFuture;
import static java.util.Arrays.asList;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static java.util.concurrent.TimeUnit.SECONDS;
import static org.junit.Assert.assertThrows;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 30 22:03:28 GMT 2025
    - 91.1K bytes
    - Click Count (0)
  4. github.com/google/guava

    guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java 

    import static com.google.common.util.concurrent.Futures.immediateCancelledFuture;
import static com.google.common.util.concurrent.Futures.immediateFailedFuture;
import static com.google.common.util.concurrent.Futures.immediateFuture;
import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
import static com.google.common.util.concurrent.SneakyThrows.sneakyThrow;
import static java.util.concurrent.Executors.callable;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  5. github.com/google/guava

    android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java 

          ListenableFuture<? extends O> output = function.apply(input);
      checkNotNull(
          output,
          "AsyncFunction.apply returned null instead of a Future. "
              + "Did you mean to return immediateFuture(null)? %s",
          function);
      return output;
    }

    @Override
    void setResult(ListenableFuture<? extends O> result) {
      setFuture(result);
    }
  }

  /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 20 18:03:37 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  6. github.com/google/guava

    android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java 

    import static com.google.common.util.concurrent.Futures.immediateCancelledFuture;
import static com.google.common.util.concurrent.Futures.immediateFailedFuture;
import static com.google.common.util.concurrent.Futures.immediateFuture;
import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
import static com.google.common.util.concurrent.SneakyThrows.sneakyThrow;
import static java.util.concurrent.Executors.callable;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  7. github.com/google/guava

    guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java 

          ListenableFuture<? extends O> output = function.apply(input);
      checkNotNull(
          output,
          "AsyncFunction.apply returned null instead of a Future. "
              + "Did you mean to return immediateFuture(null)? %s",
          function);
      return output;
    }

    @Override
    void setResult(ListenableFuture<? extends O> result) {
      setFuture(result);
    }
  }

  /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 20 18:03:37 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  8. github.com/google/guava

    guava/src/com/google/common/cache/LocalCache.java 

                return newValue;
          }
          try {
            return getAndRecordStats(key, hash, computingValueReference, immediateFuture(newValue));
          } catch (ExecutionException exception) {
            throw new AssertionError("impossible; Futures.immediateFuture can't throw");
          }
        } else if (createNewEntry || valueReference.isLoading()) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 19:35:11 GMT 2025
    - 148.9K bytes
    - Click Count (0)
  9. github.com/google/guava

    android/guava/src/com/google/common/util/concurrent/ClosingFuture.java 

    import static com.google.common.util.concurrent.ClosingFuture.State.WILL_CREATE_VALUE_AND_CLOSER;
import static com.google.common.util.concurrent.Futures.getDone;
import static com.google.common.util.concurrent.Futures.immediateFuture;
import static com.google.common.util.concurrent.Futures.nonCancellationPropagating;
import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 13:51:27 GMT 2025
    - 96.9K bytes
    - Click Count (0)
Back to Top