Combiner5<V1, V2, V3, V4, V5> whenAllSucceed(
          ClosingFuture<V1> future1,
          ClosingFuture<V2> future2,
          ClosingFuture<V3> future3,
          ClosingFuture<V4> future4,
          ClosingFuture<V5> future5) {
    return new Combiner5<>(future1, future2, future3, future4, future5);
  }

  /**
   * Starts specifying how to combine {@link ClosingFuture}s into a single pipeline, assuming they

    ClosingFuture<String> input1 = ClosingFuture.from(immediateFuture("value1"));
    ClosingFuture<Object> input2Failed = failedClosingFuture();
    ClosingFuture<String> nonInput = ClosingFuture.from(immediateFuture("value3"));
    AtomicReference<ClosingFuture.Peeker> capturedPeeker = new AtomicReference<>();
    ClosingFuture<TestCloseable> closingFuture =

    assertThat(closingFuture.cancel(false)).isTrue();
    ValueAndCloser<?> unused = finishToValueAndCloser(closingFuture);
    waitUntilClosed(closingFuture);
    futureCancelled.countDown();
  }

  private <V> ValueAndCloser<V> finishToValueAndCloser(ClosingFuture<V> closingFuture) {
    CountDownLatch valueAndCloserSet = new CountDownLatch(1);
    closingFuture.finishToValueAndCloser(

    assertDerivingThrowsIllegalStateException(closingFuture);
  }

  @Override
  <T> T getFinalValue(ClosingFuture<T> closingFuture) throws ExecutionException {
    return getUninterruptibly(closingFuture.finishToFuture());
  }

  @Override
  void assertFinallyFailsWithException(ClosingFuture<?> closingFuture) {
    assertThatFutureFailsWithException(closingFuture.finishToFuture());
  }

    ClosingFuture<String> input1 = ClosingFuture.from(immediateFuture("value1"));
    ClosingFuture<Object> input2Failed = failedClosingFuture();
    ClosingFuture<String> nonInput = ClosingFuture.from(immediateFuture("value3"));
    AtomicReference<ClosingFuture.Peeker> capturedPeeker = new AtomicReference<>();
    ClosingFuture<TestCloseable> closingFuture =

    assertThat(closingFuture.cancel(false)).isTrue();
    ValueAndCloser<?> unused = finishToValueAndCloser(closingFuture);
    waitUntilClosed(closingFuture);
    futureCancelled.countDown();
  }

  private <V> ValueAndCloser<V> finishToValueAndCloser(ClosingFuture<V> closingFuture) {
    CountDownLatch valueAndCloserSet = new CountDownLatch(1);
    closingFuture.finishToValueAndCloser(

    assertDerivingThrowsIllegalStateException(closingFuture);
  }

  @Override
  <T> T getFinalValue(ClosingFuture<T> closingFuture) throws ExecutionException {
    return getUninterruptibly(closingFuture.finishToFuture());
  }

  @Override
  void assertFinallyFailsWithException(ClosingFuture<?> closingFuture) {
    assertThatFutureFailsWithException(closingFuture.finishToFuture());
  }

/** Tests for {@link ClosingFuture} leaks. */
@NullUnmarked
@GwtIncompatible
@J2ktIncompatible
public class ClosingFutureLeakTest extends TestCase {
  public void testLeak() {
    TestCloseable closeable = new TestCloseable("closeable");
    awaitClear(leakClosingFuture(closeable));
    assertThat(closeable.awaitClosed()).isTrue();
  }

/** Tests for {@link ClosingFuture} leaks. */
@NullUnmarked
@GwtIncompatible
@J2ktIncompatible
public class ClosingFutureLeakTest extends TestCase {
  public void testLeak() {
    TestCloseable closeable = new TestCloseable("closeable");
    awaitClear(leakClosingFuture(closeable));
    assertThat(closeable.awaitClosed()).isTrue();
  }