Searched defs:closingFuture (Results 1 – 9 of 9) sorted by relevance
117 ClosingFuture<String> closingFuture = in testFrom() local142 ClosingFuture<String> closingFuture = in testEventuallyClosing() local172 ClosingFuture<TestCloseable> closingFuture = in testEventuallyClosing_cancelledPipeline() local206 ClosingFuture<String> closingFuture = in testSubmit() local234 ClosingFuture<TestCloseable> closingFuture = in testSubmit_cancelledPipeline() local255 ClosingFuture<Object> closingFuture = in testSubmit_throws() local272 ClosingFuture<TestCloseable> closingFuture = in testSubmitAsync() local296 ClosingFuture<TestCloseable> closingFuture = in testSubmitAsync_cancelledPipeline() local325 ClosingFuture<Object> closingFuture = in testSubmitAsync_throws() local343 ClosingFuture<String> closingFuture = in testAutoCloseable() local[all …]
53 ClosingFuture<Closeable> closingFuture = in testFinishToValueAndCloser_throwsIfCalledTwice() local73 ClosingFuture<Closeable> closingFuture = in testFinishToValueAndCloser_throwsAfterCallingFinishToFuture() local92 <T> T getFinalValue(ClosingFuture<T> closingFuture) throws ExecutionException { in getFinalValue()97 void assertFinallyFailsWithException(ClosingFuture<?> closingFuture) { in assertFinallyFailsWithException()110 void assertBecomesCanceled(ClosingFuture<?> closingFuture) throws ExecutionException { in assertBecomesCanceled()115 void waitUntilClosed(ClosingFuture<?> closingFuture) { in waitUntilClosed()123 void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) { in cancelFinalStepAndWait()130 private <V> ValueAndCloser<V> finishToValueAndCloser(ClosingFuture<V> closingFuture) { in finishToValueAndCloser()
32 ClosingFuture<Closeable> closingFuture = in testFinishToFuture_throwsIfCalledTwice() local50 ClosingFuture<Closeable> closingFuture = in testFinishToFuture_throwsAfterCallingFinishToValueAndCloser() local68 ClosingFuture<String> closingFuture = ClosingFuture.from(immediateFuture("value1")); in testFinishToFuture_preventsFurtherDerivation() local74 <T> T getFinalValue(ClosingFuture<T> closingFuture) throws ExecutionException { in getFinalValue()79 void assertFinallyFailsWithException(ClosingFuture<?> closingFuture) { in assertFinallyFailsWithException()84 void assertBecomesCanceled(ClosingFuture<?> closingFuture) throws ExecutionException { in assertBecomesCanceled()89 void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) { in cancelFinalStepAndWait()
117 ClosingFuture<String> closingFuture = in testFrom() local142 ClosingFuture<String> closingFuture = in testEventuallyClosing() local172 ClosingFuture<TestCloseable> closingFuture = in testEventuallyClosing_cancelledPipeline() local206 ClosingFuture<String> closingFuture = in testSubmit() local234 ClosingFuture<TestCloseable> closingFuture = in testSubmit_cancelledPipeline() local255 ClosingFuture<Object> closingFuture = in testSubmit_throws() local272 ClosingFuture<TestCloseable> closingFuture = in testSubmitAsync() local296 ClosingFuture<TestCloseable> closingFuture = in testSubmitAsync_cancelledPipeline() local325 ClosingFuture<Object> closingFuture = in testSubmitAsync_throws() local342 ClosingFuture<String> closingFuture = in testStatusFuture() local[all …]
331 private final ClosingFuture<? extends V> closingFuture; field in ClosingFuture.ValueAndCloser333 ValueAndCloser(ClosingFuture<? extends V> closingFuture) { in ValueAndCloser()441 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