Searched defs:closingFuture (Results 1 – 9 of 9) sorted by relevance
118 ClosingFuture<String> closingFuture = in testFrom() local143 ClosingFuture<String> closingFuture = in testEventuallyClosing() local173 ClosingFuture<TestCloseable> closingFuture = in testEventuallyClosing_cancelledPipeline() local207 ClosingFuture<String> closingFuture = in testSubmit() local235 ClosingFuture<TestCloseable> closingFuture = in testSubmit_cancelledPipeline() local256 ClosingFuture<Object> closingFuture = in testSubmit_throws() local273 ClosingFuture<TestCloseable> closingFuture = in testSubmitAsync() local297 ClosingFuture<TestCloseable> closingFuture = in testSubmitAsync_cancelledPipeline() local326 ClosingFuture<Object> closingFuture = in testSubmitAsync_throws() local344 ClosingFuture<String> closingFuture = in testAutoCloseable() local[all …]
33 ClosingFuture<Closeable> closingFuture = in testFinishToFuture_throwsIfCalledTwice() local51 ClosingFuture<Closeable> closingFuture = in testFinishToFuture_throwsAfterCallingFinishToValueAndCloser() local69 ClosingFuture<String> closingFuture = ClosingFuture.from(immediateFuture("value1")); in testFinishToFuture_preventsFurtherDerivation() local75 <T> T getFinalValue(ClosingFuture<T> closingFuture) throws ExecutionException { in getFinalValue()80 void assertFinallyFailsWithException(ClosingFuture<?> closingFuture) { in assertFinallyFailsWithException()85 void assertBecomesCanceled(ClosingFuture<?> closingFuture) throws ExecutionException { in assertBecomesCanceled()90 void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) { in cancelFinalStepAndWait()
54 ClosingFuture<Closeable> closingFuture = in testFinishToValueAndCloser_throwsIfCalledTwice() local73 ClosingFuture<Closeable> closingFuture = in testFinishToValueAndCloser_throwsAfterCallingFinishToFuture() local91 <T> T getFinalValue(ClosingFuture<T> closingFuture) throws ExecutionException { in getFinalValue()96 void assertFinallyFailsWithException(ClosingFuture<?> closingFuture) { in assertFinallyFailsWithException()109 void assertBecomesCanceled(ClosingFuture<?> closingFuture) throws ExecutionException { in assertBecomesCanceled()114 void waitUntilClosed(ClosingFuture<?> closingFuture) { in waitUntilClosed()122 void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) { in cancelFinalStepAndWait()129 private <V> ValueAndCloser<V> finishToValueAndCloser(ClosingFuture<V> closingFuture) { in finishToValueAndCloser()
118 ClosingFuture<String> closingFuture = in testFrom() local143 ClosingFuture<String> closingFuture = in testEventuallyClosing() local173 ClosingFuture<TestCloseable> closingFuture = in testEventuallyClosing_cancelledPipeline() local207 ClosingFuture<String> closingFuture = in testSubmit() local235 ClosingFuture<TestCloseable> closingFuture = in testSubmit_cancelledPipeline() local256 ClosingFuture<Object> closingFuture = in testSubmit_throws() local273 ClosingFuture<TestCloseable> closingFuture = in testSubmitAsync() local297 ClosingFuture<TestCloseable> closingFuture = in testSubmitAsync_cancelledPipeline() local326 ClosingFuture<Object> closingFuture = in testSubmitAsync_throws() local343 ClosingFuture<String> closingFuture = in testStatusFuture() local[all …]
332 private final ClosingFuture<? extends V> closingFuture; field in ClosingFuture.ValueAndCloser334 ValueAndCloser(ClosingFuture<? extends V> closingFuture) { in ValueAndCloser()442 final ClosingFuture<C> closingFuture = new ClosingFuture<>(nonCancellationPropagating(future)); in eventuallyClosing() local
329 private final ClosingFuture<? extends V> closingFuture; field in ClosingFuture.ValueAndCloser331 ValueAndCloser(ClosingFuture<? extends V> closingFuture) { in ValueAndCloser()439 final ClosingFuture<C> closingFuture = new ClosingFuture<>(nonCancellationPropagating(future)); in eventuallyClosing() local
351 ClosingFuture<DownloadResult> closingFuture = enqueueRequest(request); in execute() local