Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 48 for ImmediateFuture (0.11 seconds)

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

    /** Implementation of {@link Futures#immediateFuture}. */
    @GwtCompatible
    // TODO(cpovirk): Make this final (but that may break Mockito spy calls).
    class ImmediateFuture<V extends @Nullable Object> implements ListenableFuture<V> {
      static final ListenableFuture<?> NULL = new ImmediateFuture<@Nullable Object>(null);
    
      private static final LazyLogger log = new LazyLogger(ImmediateFuture.class);
    
      @ParametricNullness private final V value;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 3.4K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

            ClosingFuture.whenAllSucceed(
                    ClosingFuture.eventuallyClosing(immediateFuture(closeable1), closingExecutor),
                    ClosingFuture.from(immediateFuture("value2")),
                    ClosingFuture.from(immediateFuture("value3")),
                    ClosingFuture.from(immediateFuture("value4")),
                    ClosingFuture.from(immediateFuture("value5")))
                .call(
                    (DeferredCloser closer,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 63K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

        ListenableFuture<String> f =
            new SimpleForwardingListenableFuture<String>(immediateFuture("a")) {};
        verify(!(f instanceof FluentFuture));
        assertThat(FluentFuture.from(f).get()).isEqualTo("a");
        // TODO(cpovirk): Test forwarding more extensively.
      }
    
      public void testAddCallback() {
        FluentFuture<String> f = FluentFuture.from(immediateFuture("a"));
        boolean[] called = new boolean[1];
        f.addCallback(
    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)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

            ClosingFuture.whenAllSucceed(
                    ClosingFuture.eventuallyClosing(immediateFuture(closeable1), closingExecutor),
                    ClosingFuture.from(immediateFuture("value2")),
                    ClosingFuture.from(immediateFuture("value3")),
                    ClosingFuture.from(immediateFuture("value4")),
                    ClosingFuture.from(immediateFuture("value5")))
                .call(
                    (DeferredCloser closer,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 63K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

        ListenableFuture<String> f =
            new SimpleForwardingListenableFuture<String>(immediateFuture("a")) {};
        verify(!(f instanceof FluentFuture));
        assertThat(FluentFuture.from(f).get()).isEqualTo("a");
        // TODO(cpovirk): Test forwarding more extensively.
      }
    
      public void testAddCallback() {
        FluentFuture<String> f = FluentFuture.from(immediateFuture("a"));
        boolean[] called = new boolean[1];
        f.addCallback(
    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-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

    import static com.google.common.util.concurrent.ClassPathUtil.parseJavaClassPath;
    import static com.google.common.util.concurrent.Futures.getChecked;
    import static com.google.common.util.concurrent.Futures.immediateFuture;
    import static com.google.common.util.concurrent.FuturesGetCheckedInputs.CHECKED_EXCEPTION;
    import static com.google.common.util.concurrent.FuturesGetCheckedInputs.ERROR;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 16.5K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

    import static com.google.common.util.concurrent.ClassPathUtil.parseJavaClassPath;
    import static com.google.common.util.concurrent.Futures.getChecked;
    import static com.google.common.util.concurrent.Futures.immediateFuture;
    import static com.google.common.util.concurrent.FuturesGetCheckedInputs.CHECKED_EXCEPTION;
    import static com.google.common.util.concurrent.FuturesGetCheckedInputs.ERROR;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 16.5K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

      public void testGetUnchecked_success() {
        assertThat(getUnchecked(immediateFuture("foo"))).isEqualTo("foo");
      }
    
      @J2ktIncompatible
      @GwtIncompatible // Thread.interrupt
      public void testGetUnchecked_interrupted() {
        Thread.currentThread().interrupt();
        try {
          assertThat(getUnchecked(immediateFuture("foo"))).isEqualTo("foo");
          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 4.6K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

      public void testGetUnchecked_success() {
        assertThat(getUnchecked(immediateFuture("foo"))).isEqualTo("foo");
      }
    
      @J2ktIncompatible
      @GwtIncompatible // Thread.interrupt
      public void testGetUnchecked_interrupted() {
        Thread.currentThread().interrupt();
        try {
          assertThat(getUnchecked(immediateFuture("foo"))).isEqualTo("foo");
          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 4.6K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        // Since holder.value is 2, applying 4 should yield 6.
        assertEquals(6, adder.apply(4).intValue());
    
        ListenableFuture<Integer> immediateFuture = immediateFuture(4);
        Future<Integer> transformedFuture = transform(immediateFuture, adder, directExecutor());
    
        // The composed future also yields 6.
        assertEquals(6, getDone(transformedFuture).intValue());
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
Back to Top