testTransformAsync_interruptPropagatesToAsyncOutput

Sort Score
Result 10 results
Languages All

Results 1 - 2 of 2 for testTransformAsync_interruptPropagatesToAsyncOutput (0.38 sec)

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

    assertTrue(transformAsync(immediate, function, directExecutor()).cancel(false));
    assertTrue(secondary.isCancelled());
    assertFalse(secondary.wasInterrupted());
  }

  public void testTransformAsync_interruptPropagatesToAsyncOutput() throws Exception {
    ListenableFuture<Foo> immediate = immediateFuture(new Foo());
    final SettableFuture<Bar> secondary = SettableFuture.create();
    AsyncFunction<Foo, Bar> function =

Registered: Wed Jun 12 16:38:11 UTC 2024

- Last Modified: Wed May 29 16:29:37 UTC 2024

- 144.1K bytes

- Viewed (0)

github.com/google/guava

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

    assertTrue(transformAsync(immediate, function, directExecutor()).cancel(false));
    assertTrue(secondary.isCancelled());
    assertFalse(secondary.wasInterrupted());
  }

  public void testTransformAsync_interruptPropagatesToAsyncOutput() throws Exception {
    ListenableFuture<Foo> immediate = immediateFuture(new Foo());
    final SettableFuture<Bar> secondary = SettableFuture.create();
    AsyncFunction<Foo, Bar> function =