Searched refs:outputFuture (Results 1 – 3 of 3) sorted by relevance
39 private SettableFuture<String> outputFuture; field in FuturesTransformAsyncFunctionTest47 outputFuture = SettableFuture.create(); in buildChainingFuture()61 case VALID_INPUT_DATA: outputFuture.set(RESULT_DATA); break; in apply()69 return outputFuture; in apply()91 outputFuture.cancel(true); // argument is ignored in testFutureGetThrowsCancellationIfOutputCancelled()103 assertFalse(outputFuture.isCancelled()); in testFutureCancelBeforeInputCompletion()116 assertTrue(outputFuture.isCancelled()); in testFutureCancellableBeforeOutputCompletion()138 assertFalse(outputFuture.isCancelled()); in testFutureCancellableBeforeFunctionCompletion()147 outputFuture.get(); in testFutureCancellableBeforeFunctionCompletion()158 assertFalse(outputFuture.isCancelled()); in testFutureCancelAfterCompletion()
701 ListenableFuture<Integer> outputFuture = Futures.transform(inputFuture, function);704 outputFuture.get();
625 final AbstractFuture<?> outputFuture, in rejectionPropagatingRunnable() argument641 outputFuture.setException(e); in rejectionPropagatingRunnable()856 private volatile ListenableFuture<? extends O> outputFuture;875 cancel(outputFuture, mayInterruptIfRunning);906 final ListenableFuture<? extends O> outputFuture = this.outputFuture =910 outputFuture.cancel(wasInterrupted());911 this.outputFuture = null;914 outputFuture.addListener(new Runnable() {918 set(getUninterruptibly(outputFuture));930 ChainingListenableFuture.this.outputFuture = null;[all …]