output.addListener(
        () -> {
          throw new SomeError();
        },
        directExecutor());
    assertThrows(SomeError.class, () -> input.set("foo"));
  }

  public void testTransformAsync_cancelPropagatesToInput() throws Exception {
    SettableFuture<Foo> input = SettableFuture.create();
    AsyncFunction<Foo, Bar> function =
        unused -> {
          throw new AssertionFailedError("Unexpected call to apply.");

    output.addListener(
        () -> {
          throw new SomeError();
        },
        directExecutor());
    assertThrows(SomeError.class, () -> input.set("foo"));
  }

  public void testTransformAsync_cancelPropagatesToInput() throws Exception {
    SettableFuture<Foo> input = SettableFuture.create();
    AsyncFunction<Foo, Bar> function =
        unused -> {
          throw new AssertionFailedError("Unexpected call to apply.");

cpovirk <******@****.***> 1773701012 -0700

cpovirk <******@****.***> 1773701012 -0700