Searched refs:inputFuture (Results 1 – 5 of 5) sorted by relevance
46 ListenableFuture<Integer> inputFuture) { in buildChainingFuture() argument50 return Futures.transform(inputFuture, new ChainingFunction()); in buildChainingFuture()74 inputFuture.set(EXCEPTION_DATA); in testFutureGetThrowsFunctionException()80 inputFuture.cancel(true); // argument is ignored in testFutureGetThrowsCancellationIfInputCancelled()90 inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); in testFutureGetThrowsCancellationIfOutputCancelled()102 assertTrue(inputFuture.isCancelled()); in testFutureCancelBeforeInputCompletion()112 inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); in testFutureCancellableBeforeOutputCompletion()115 assertFalse(inputFuture.isCancelled()); in testFutureCancellableBeforeOutputCompletion()130 inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA); in testFutureCancellableBeforeFunctionCompletion()137 assertFalse(inputFuture.isCancelled()); in testFutureCancellableBeforeFunctionCompletion()[all …]
38 protected SettableFuture<Integer> inputFuture; field in AbstractChainedListenableFutureTest46 inputFuture = SettableFuture.create(); in setUp()47 resultFuture = buildChainingFuture(inputFuture); in setUp()61 inputFuture.setException(EXCEPTION); in testFutureGetThrowsWrappedException()67 inputFuture.setException(error); in testFutureGetThrowsWrappedError()74 inputFuture.set(VALID_INPUT_DATA); in testAddListenerAfterCallback()80 inputFuture.set(VALID_INPUT_DATA); in testFutureBeforeCallback()91 ListenableFuture<Integer> inputFuture); in buildChainingFuture() argument
33 ListenableFuture<Integer> inputFuture) { in buildChainingFuture() argument34 return Futures.transform(inputFuture, in buildChainingFuture()55 inputFuture.set(EXCEPTION_DATA); in testFutureGetThrowsFunctionException()
700 SettableFuture<String> inputFuture = SettableFuture.create();701 ListenableFuture<Integer> outputFuture = Futures.transform(inputFuture, function);702 inputFuture.set("value");723 SettableFuture<String> inputFuture = SettableFuture.create();725 inputFuture, function, Executors.newSingleThreadExecutor());726 inputFuture.set("value");
855 private ListenableFuture<? extends I> inputFuture;860 ListenableFuture<? extends I> inputFuture) {862 this.inputFuture = checkNotNull(inputFuture);874 cancel(inputFuture, mayInterruptIfRunning);893 sourceResult = getUninterruptibly(inputFuture);944 inputFuture = null;