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());
  }

    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();
  }

 * or implied. See the License for the specific language governing permissions and limitations under
 * the License.
 */

/**
 * Concurrency utilities.
 *
 * <p>Commonly used types include {@link ClosingFuture}, {@link ListenableFuture}, and {@link
 * Service}.
 *
 * <p>Commonly used utilities include {@link Futures}, {@link MoreExecutors}, {@link
 * ThreadFactoryBuilder}, and {@link Uninterruptibles}.
 *