Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 15 for ForwardingListenableFuture (0.2 seconds)

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

     * invoke methods, they invoke methods on the {@code ForwardingListenableFuture}.
     *
     * <p>Most subclasses can just use {@link SimpleForwardingListenableFuture}.
     *
     * @author Shardul Deo
     * @since 4.0
     */
    @GwtCompatible
    public abstract class ForwardingListenableFuture<V extends @Nullable Object>
        extends ForwardingFuture<V> implements ListenableFuture<V> {
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 3K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/ForwardingListenableFutureTest.java

    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for {@link ForwardingListenableFuture}.
     *
     * @author Ben Yu
     */
    @NullUnmarked
    @GwtIncompatible
    @J2ktIncompatible
    public class ForwardingListenableFutureTest extends TestCase {
      public void testForwarding() {
        ForwardingObjectTester.testForwardingObject(ForwardingListenableFuture.class);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 1.1K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ForwardingListenableFutureTest.java

    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for {@link ForwardingListenableFuture}.
     *
     * @author Ben Yu
     */
    @NullUnmarked
    @GwtIncompatible
    @J2ktIncompatible
    public class ForwardingListenableFutureTest extends TestCase {
      public void testForwarding() {
        ForwardingObjectTester.testForwardingObject(ForwardingListenableFuture.class);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 1.1K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java

     * 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
    final class ForwardingFluentFuture<V extends @Nullable Object> extends FluentFuture<V> {
      private final ListenableFuture<V> delegate;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 3.1K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

     * 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.
     *
     * @since 23.0
     */
    @DoNotMock("Use FluentFuture.from(Futures.immediate*Future) or SettableFuture")
    @GwtCompatible
    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)
  6. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        SettableFuture<Object> orig = SettableFuture.create();
        // unlike the above this indirection defeats the trivial cycle detection and causes a SOE
        orig.setFuture(
            new ForwardingListenableFuture<Object>() {
              @Override
              protected ListenableFuture<Object> delegate() {
                return orig;
              }
            });
        assertThat(orig.toString())
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        SettableFuture<Object> orig = SettableFuture.create();
        // unlike the above this indirection defeats the trivial cycle detection and causes a SOE
        orig.setFuture(
            new ForwardingListenableFuture<Object>() {
              @Override
              protected ListenableFuture<Object> delegate() {
                return orig;
              }
            });
        assertThat(orig.toString())
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFuture;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeoutException;
    import junit.framework.TestCase;
    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)
  9. guava-tests/test/com/google/common/util/concurrent/ListeningScheduledExecutorServiceTest.java

    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFuture;
    import java.time.Duration;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.Delayed;
    import java.util.concurrent.TimeUnit;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 6.5K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFuture;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeoutException;
    import junit.framework.TestCase;
    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)
Back to Top