Home
last modified time | relevance | path

Searched refs:inputFuture (Results 1 – 15 of 15) sorted by relevance

/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractChainedListenableFutureTest.java37 protected SettableFuture<Integer> inputFuture; field in AbstractChainedListenableFutureTest
45 inputFuture = SettableFuture.create(); in setUp()
46 resultFuture = buildChainingFuture(inputFuture); in setUp()
60 inputFuture.setException(EXCEPTION); in testFutureGetThrowsWrappedException()
66 inputFuture.setException(error); in testFutureGetThrowsWrappedError()
73 inputFuture.set(VALID_INPUT_DATA); in testAddListenerAfterCallback()
79 inputFuture.set(VALID_INPUT_DATA); in testFutureBeforeCallback()
85 assertThat(resultFuture.toString()).contains(inputFuture.toString()); in testInputFutureToString()
93 protected abstract ListenableFuture<T> buildChainingFuture(ListenableFuture<Integer> inputFuture); in buildChainingFuture() argument
DFuturesTransformAsyncTest.java46 protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) { in buildChainingFuture() argument
50 return transformAsync(inputFuture, new ChainingFunction(), directExecutor()); in buildChainingFuture()
79 inputFuture.set(EXCEPTION_DATA); in testFutureGetThrowsFunctionException()
84 inputFuture.cancel(true); // argument is ignored in testFutureGetThrowsCancellationIfInputCancelled()
93 inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); in testFutureGetThrowsCancellationIfOutputCancelled()
105 inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); in testAsyncToString()
112 assertTrue(inputFuture.isCancelled()); in testFutureCancelBeforeInputCompletion()
122 inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); in testFutureCancellableBeforeOutputCompletion()
125 assertFalse(inputFuture.isCancelled()); in testFutureCancellableBeforeOutputCompletion()
140 inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA); in testFutureCancellableBeforeFunctionCompletion()
[all …]
DFuturesTransformTest.java36 protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) { in buildChainingFuture() argument
37 return transform(inputFuture, new ComposeFunction(), directExecutor()); in buildChainingFuture()
57 inputFuture.set(EXCEPTION_DATA); in testFutureGetThrowsFunctionException()
DFuturesTest.java1107 ListenableFuture<Integer> inputFuture = immediateFailedFuture(new Exception());
1110 inputFuture,
1719 SettableFuture<String> inputFuture = SettableFuture.create();
1721 transformAsync(inputFuture, function, directExecutor());
1722 inputFuture.set("value");
1732 ListenableFuture<?> inputFuture = immediateFuture("a");
1734 transformAsync(inputFuture, constantAsyncFunction(null), directExecutor());
1763 SettableFuture<String> inputFuture = SettableFuture.create();
1765 transformAsync(inputFuture, function, newSingleThreadExecutor());
1766 inputFuture.set("value");
[all …]
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DAbstractChainedListenableFutureTest.java37 protected SettableFuture<Integer> inputFuture; field in AbstractChainedListenableFutureTest
45 inputFuture = SettableFuture.create(); in setUp()
46 resultFuture = buildChainingFuture(inputFuture); in setUp()
60 inputFuture.setException(EXCEPTION); in testFutureGetThrowsWrappedException()
66 inputFuture.setException(error); in testFutureGetThrowsWrappedError()
73 inputFuture.set(VALID_INPUT_DATA); in testAddListenerAfterCallback()
79 inputFuture.set(VALID_INPUT_DATA); in testFutureBeforeCallback()
85 assertThat(resultFuture.toString()).contains(inputFuture.toString()); in testInputFutureToString()
93 protected abstract ListenableFuture<T> buildChainingFuture(ListenableFuture<Integer> inputFuture); in buildChainingFuture() argument
DFuturesTransformAsyncTest.java46 protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) { in buildChainingFuture() argument
50 return transformAsync(inputFuture, new ChainingFunction(), directExecutor()); in buildChainingFuture()
79 inputFuture.set(EXCEPTION_DATA); in testFutureGetThrowsFunctionException()
84 inputFuture.cancel(true); // argument is ignored in testFutureGetThrowsCancellationIfInputCancelled()
93 inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); in testFutureGetThrowsCancellationIfOutputCancelled()
105 inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); in testAsyncToString()
112 assertTrue(inputFuture.isCancelled()); in testFutureCancelBeforeInputCompletion()
122 inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); in testFutureCancellableBeforeOutputCompletion()
125 assertFalse(inputFuture.isCancelled()); in testFutureCancellableBeforeOutputCompletion()
140 inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA); in testFutureCancellableBeforeFunctionCompletion()
[all …]
DFuturesTransformTest.java36 protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) { in buildChainingFuture() argument
37 return transform(inputFuture, new ComposeFunction(), directExecutor()); in buildChainingFuture()
57 inputFuture.set(EXCEPTION_DATA); in testFutureGetThrowsFunctionException()
DFuturesTest.java1107 ListenableFuture<Integer> inputFuture = immediateFailedFuture(new Exception());
1110 inputFuture,
1719 SettableFuture<String> inputFuture = SettableFuture.create();
1721 transformAsync(inputFuture, function, directExecutor());
1722 inputFuture.set("value");
1732 ListenableFuture<?> inputFuture = immediateFuture("a");
1734 transformAsync(inputFuture, constantAsyncFunction(null), directExecutor());
1763 SettableFuture<String> inputFuture = SettableFuture.create();
1765 transformAsync(inputFuture, function, newSingleThreadExecutor());
1766 inputFuture.set("value");
[all …]
/external/guava/android/guava/src/com/google/common/util/concurrent/
DAbstractTransformFuture.java59 @CheckForNull ListenableFuture<? extends I> inputFuture; field in AbstractTransformFuture
62 AbstractTransformFuture(ListenableFuture<? extends I> inputFuture, F function) { in AbstractTransformFuture() argument
63 this.inputFuture = checkNotNull(inputFuture); in AbstractTransformFuture()
69 ListenableFuture<? extends I> localInputFuture = inputFuture; in run()
74 inputFuture = null; in run()
181 maybePropagateCancellationTo(inputFuture); in afterDone()
182 this.inputFuture = null; in afterDone()
189 ListenableFuture<? extends I> localInputFuture = inputFuture; in pendingToString()
213 ListenableFuture<? extends I> inputFuture, AsyncFunction<? super I, ? extends O> function) { in AsyncTransformFuture() argument
214 super(inputFuture, function); in AsyncTransformFuture()
[all …]
DAbstractCatchingFuture.java64 @CheckForNull ListenableFuture<? extends V> inputFuture; field in AbstractCatchingFuture
69 ListenableFuture<? extends V> inputFuture, Class<X> exceptionType, F fallback) { in AbstractCatchingFuture() argument
70 this.inputFuture = checkNotNull(inputFuture); in AbstractCatchingFuture()
77 ListenableFuture<? extends V> localInputFuture = inputFuture; in run()
85 inputFuture = null; in run()
148 ListenableFuture<? extends V> localInputFuture = inputFuture; in pendingToString()
180 maybePropagateCancellationTo(inputFuture); in afterDone()
181 this.inputFuture = null; in afterDone()
DFutures.java998 ListenableFuture<? extends T> inputFuture = requireNonNull(inputFutures[inputFutureIndex]);
1002 if (delegates.get(i).setFuture(inputFuture)) {
/external/guava/guava/src/com/google/common/util/concurrent/
DAbstractTransformFuture.java59 @CheckForNull ListenableFuture<? extends I> inputFuture; field in AbstractTransformFuture
62 AbstractTransformFuture(ListenableFuture<? extends I> inputFuture, F function) { in AbstractTransformFuture() argument
63 this.inputFuture = checkNotNull(inputFuture); in AbstractTransformFuture()
69 ListenableFuture<? extends I> localInputFuture = inputFuture; in run()
74 inputFuture = null; in run()
181 maybePropagateCancellationTo(inputFuture); in afterDone()
182 this.inputFuture = null; in afterDone()
189 ListenableFuture<? extends I> localInputFuture = inputFuture; in pendingToString()
213 ListenableFuture<? extends I> inputFuture, AsyncFunction<? super I, ? extends O> function) { in AsyncTransformFuture() argument
214 super(inputFuture, function); in AsyncTransformFuture()
[all …]
DAbstractCatchingFuture.java64 @CheckForNull ListenableFuture<? extends V> inputFuture; field in AbstractCatchingFuture
69 ListenableFuture<? extends V> inputFuture, Class<X> exceptionType, F fallback) { in AbstractCatchingFuture() argument
70 this.inputFuture = checkNotNull(inputFuture); in AbstractCatchingFuture()
77 ListenableFuture<? extends V> localInputFuture = inputFuture; in run()
85 inputFuture = null; in run()
148 ListenableFuture<? extends V> localInputFuture = inputFuture; in pendingToString()
180 maybePropagateCancellationTo(inputFuture); in afterDone()
181 this.inputFuture = null; in afterDone()
DFutures.java1031 ListenableFuture<? extends T> inputFuture = requireNonNull(inputFutures[inputFutureIndex]);
1035 if (delegates.get(i).setFuture(inputFuture)) {
/external/dagger2/java/dagger/internal/codegen/writing/
DOptionalFactories.java437 OptionalKind optionalKind, TypeName inputType, CodeBlock inputFuture) {
441 inputFuture,