Searched refs:resultFuture (Results 1 – 4 of 4) sorted by relevance
82 resultFuture.get(); in testFutureGetThrowsCancellationIfInputCancelled()93 resultFuture.get(); in testFutureGetThrowsCancellationIfOutputCancelled()100 assertTrue(resultFuture.cancel(true)); in testFutureCancelBeforeInputCompletion()101 assertTrue(resultFuture.isCancelled()); in testFutureCancelBeforeInputCompletion()105 resultFuture.get(); in testFutureCancelBeforeInputCompletion()113 assertTrue(resultFuture.cancel(true)); in testFutureCancellableBeforeOutputCompletion()114 assertTrue(resultFuture.isCancelled()); in testFutureCancellableBeforeOutputCompletion()118 resultFuture.get(); in testFutureCancellableBeforeOutputCompletion()135 assertTrue(resultFuture.cancel(true)); in testFutureCancellableBeforeFunctionCompletion()136 assertTrue(resultFuture.isCancelled()); in testFutureCancellableBeforeFunctionCompletion()[all …]
39 protected ListenableFuture<T> resultFuture; field in AbstractChainedListenableFutureTest47 resultFuture = buildChainingFuture(inputFuture); in setUp()48 listener = new MockFutureListener(resultFuture); in setUp()55 resultFuture.get(1L, TimeUnit.MILLISECONDS); in testFutureGetBeforeCallback()
715 final SettableFuture<Integer> resultFuture = SettableFuture.create();720 return resultFuture;735 resultFuture.get();
113 final SettableFuture<String> resultFuture = SettableFuture.create(); in runTest() local118 resultFuture.set(result); in runTest()133 String result = resultFuture.get(TIMEOUT_SECONDS, TimeUnit.SECONDS); in runTest()