| /external/pigweed/pw_transfer/java/test/dev/pigweed/pw_transfer/ |
| D | TransferClientTest.java | 81 ListenableFuture<byte[]> future = transferClient.read(1); in legacy_read_singleChunk_successful() local
96 ListenableFuture<byte[]> future = transferClient.read(1, params); in legacy_read_failedPreconditionError_aborts() local
120 ListenableFuture<byte[]> future = transferClient.read(1); in legacy_read_singleChunk_ignoresUnknownIdOrWriteChunks() local
155 ListenableFuture<byte[]> future = transferClient.read(2); in legacy_read_empty() local
169 ListenableFuture<byte[]> future = transferClient.read(99, params); in legacy_read_sendsTransferParametersFirst() local
178 ListenableFuture<byte[]> future = transferClient.read(123, TRANSFER_PARAMETERS); in legacy_read_severalChunks() local
230 ListenableFuture<byte[]> future = transferClient.read(123, params); in legacy_read_adaptiveWindow_slowStart() local
279 ListenableFuture<byte[]> future = transferClient.read(123, params); in legacy_read_adaptiveWindow_congestionAvoidance() local
338 ListenableFuture<byte[]> future = in legacy_read_progressCallbackIsCalled() local
372 ListenableFuture<byte[]> future = transferClient.read(123, TRANSFER_PARAMETERS); in legacy_read_rewindWhenPacketsSkipped() local
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/jdk8/future/ |
| D | AsFutureTest.kt | 23 val future = deferred.asCompletableFuture() in <lambda>() constant
31 val future = job.asCompletableFuture() in <lambda>() constant
43 val future = deferred.asCompletableFuture() in <lambda>() constant
51 val future = job.asCompletableFuture() in testWaitForJobAsCompletableFuture() constant
61 val future = deferred.asCompletableFuture() in testAsCompletableFutureThrowable() constant
77 val future = job.asCompletableFuture() in testJobAsCompletableFutureThrowable() constant
92 val future = job.asCompletableFuture() in testJobAsCompletableFutureCancellation() constant
107 val future = job.asCompletableFuture() in testJobCancellation() constant
117 val future = deferred.asCompletableFuture() in testDeferredCancellation() constant
|
| D | FutureTest.kt | 28 val future = GlobalScope.future { in testSimpleAwait() constant
40 val future = GlobalScope.future { in testCompletedFuture() constant
51 val future = GlobalScope.future { in testCompletedCompletionStage() constant
60 val future = GlobalScope.future { in testWaitForFuture() constant
72 val future = GlobalScope.future { in testWaitForCompletionStage() constant
84 val future = GlobalScope.future { in testCompletedFutureExceptionally() constant
100 val future = GlobalScope.future { in testCompletedCompletionStageExceptionally() constant
115 val future = future(start = CoroutineStart.UNDISPATCHED) { in <lambda>() constant
136 val future = GlobalScope.future { in testWaitForCompletionStageWithException() constant
150 val future = GlobalScope.future { in testExceptionInsideCoroutine() constant
[all …]
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/test/ |
| D | ListenableFutureTest.kt | 26 val future = GlobalScope.future { in testSimpleAwait() constant
36 val future = SettableFuture.create<Int>() in <lambda>() constant
49 val future = SettableFuture.create<Int>() constant
65 val future = GlobalScope.future { in testCompletedFuture() constant
74 val future = GlobalScope.future { in testWaitForFuture() constant
86 val future = GlobalScope.future { in testCompletedFutureExceptionally() constant
100 val future = GlobalScope.future { in testWaitForFutureWithException() constant
116 val future = GlobalScope.future { in testExceptionInsideCoroutine() constant
150 val future = deferred.asListenableFuture() in <lambda>() constant
163 val future = deferred.asListenableFuture() in <lambda>() constant
[all …]
|
| /external/cronet/base/test/ |
| D | test_future_unittest.cc | 74 TestFuture<int> future; in TEST_F() local
85 TestFuture<int> future; in TEST_F() local
100 static TestFuture<AnyType> future; in TEST_F() local
109 TestFuture<int> future; in TEST_F() local
122 TestFuture<AnyType> future; in TEST_F() local
129 TestFuture<MoveOnlyValue> future; in TEST_F() local
141 TestFuture<AnyType> future; in TEST_F() local
147 TestFuture<AnyType> future; in TEST_F() local
157 TestFuture<AnyType> future; in TEST_F() local
167 TestFuture<AnyType> future; in TEST_F() local
[all …]
|
| D | repeating_test_future_unittest.cc | 50 RepeatingTestFuture<std::string> future; in TEST_F() local
56 RepeatingTestFuture<std::string> future; in TEST_F() local
64 RepeatingTestFuture<std::string> future; in TEST_F() local
74 RepeatingTestFuture<std::string> future; in TEST_F() local
84 RepeatingTestFuture<std::string> future; in TEST_F() local
94 RepeatingTestFuture<std::string> future; in TEST_F() local
105 RepeatingTestFuture<std::string> future; in TEST_F() local
116 RepeatingTestFuture<std::string> future; in TEST_F() local
130 static RepeatingTestFuture<std::string> future; in TEST_F() local
138 RepeatingTestFuture<std::string> future; in TEST_F() local
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jdk8/src/future/ |
| D | Future.kt | 34 public fun <T> CoroutineScope.future( in <lambda>() method
41 val future = CompletableFuture<T>() in <lambda>() constant
50 private val future: CompletableFuture<T> constant
75 val future = CompletableFuture<T>() in asCompletableFuture() constant
92 val future = CompletableFuture<Unit>() in asCompletableFuture() constant
117 val future = toCompletableFuture() // retrieve the future in asDeferred() constant
161 val future = toCompletableFuture() // retrieve the future in await() constant
|
| /external/dagger2/javatests/dagger/producers/internal/ |
| D | ProducersTest.java | 42 ListenableFuture<String> future = Futures.immediateFuture("monkey"); in createFutureProduced_success() local
49 ListenableFuture<String> future = Futures.immediateFailedFuture(new RuntimeException("monkey")); in createFutureProduced_failure() local
59 ListenableFuture<String> future = SettableFuture.create(); in createFutureProduced_cancelPropagatesBackwards() local
67 ListenableFuture<String> future = SettableFuture.create(); in createFutureProduced_cancelDoesNotPropagateForwards() local
87 ListenableFuture<String> future = Futures.immediateFuture("monkey"); in createFutureSingletonSet_success() local
94 ListenableFuture<String> future = Futures.immediateFailedFuture(new RuntimeException("monkey")); in createFutureSingletonSet_failure() local
107 ListenableFuture<Set<String>> future = in allAsSet_success() local
117 ListenableFuture<Set<String>> future = in allAsSet_failure() local
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractFutureTest.java | 75 AbstractFuture<String> future = in testException() local
96 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneNoInterrupt() local
107 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneInterrupt() local
118 AbstractFuture<String> future = in testCancel_done() local
130 AbstractFuture<String> future = in testGetWithTimeoutDoneFuture() local
156 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_interruption() local
180 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_polling() local
209 SettableFuture<Object> future = SettableFuture.create(); in testToString_oom() local
376 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testCompletionFinishesWithDone() local
578 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testFutureBash() local
[all …]
|
| D | TestPlatform.java | 38 static void verifyGetOnPendingFuture(Future<?> future) { in verifyGetOnPendingFuture()
49 static void verifyTimedGetOnPendingFuture(Future<?> future) { in verifyTimedGetOnPendingFuture()
71 static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { in getDoneFromTimeoutOverload()
72 checkState(future.isDone(), "Future was expected to be done: %s", future); in getDoneFromTimeoutOverload() local
|
| D | UninterruptibleFutureTest.java | 181 SettableFuture<String> future = SettableFuture.create(); in runUntimedInterruptsTest() local
189 SettableFuture<String> future = SettableFuture.create(); in runTimedInterruptsTest() local
196 int times, SettableFuture<String> future, FutureTask<Boolean> interruptReporter) in runNInterruptsTest()
213 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_plainFutureSanityCheck() local
226 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetZeroTimeoutAttempted() local
238 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetNegativeTimeoutAttempted() local
249 final Future<?> future, final boolean allowInterruption) { in untimedInterruptReporter()
|
| D | FuturesTest.java | 136 ListenableFuture<String> future = immediateFuture(DATA1); in testImmediateFuture() local
153 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture() local
173 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture_cancellationException() local
193 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureBasic() local
199 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureStack() local
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractFutureTest.java | 75 AbstractFuture<String> future = in testException() local
96 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneNoInterrupt() local
107 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneInterrupt() local
118 AbstractFuture<String> future = in testCancel_done() local
130 AbstractFuture<String> future = in testGetWithTimeoutDoneFuture() local
156 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_interruption() local
180 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testRemoveWaiter_polling() local
209 SettableFuture<Object> future = SettableFuture.create(); in testToString_oom() local
376 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testCompletionFinishesWithDone() local
578 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testFutureBash() local
[all …]
|
| D | TestPlatform.java | 38 static void verifyGetOnPendingFuture(Future<?> future) { in verifyGetOnPendingFuture()
49 static void verifyTimedGetOnPendingFuture(Future<?> future) { in verifyTimedGetOnPendingFuture()
71 static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { in getDoneFromTimeoutOverload()
72 checkState(future.isDone(), "Future was expected to be done: %s", future); in getDoneFromTimeoutOverload() local
|
| D | UninterruptibleFutureTest.java | 181 SettableFuture<String> future = SettableFuture.create(); in runUntimedInterruptsTest() local
189 SettableFuture<String> future = SettableFuture.create(); in runTimedInterruptsTest() local
196 int times, SettableFuture<String> future, FutureTask<Boolean> interruptReporter) in runNInterruptsTest()
213 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_plainFutureSanityCheck() local
226 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetZeroTimeoutAttempted() local
238 SettableFuture<String> future = SettableFuture.create(); in testMakeUninterruptible_timedGetNegativeTimeoutAttempted() local
249 final Future<?> future, final boolean allowInterruption) { in untimedInterruptReporter()
|
| D | FuturesTest.java | 136 ListenableFuture<String> future = immediateFuture(DATA1); in testImmediateFuture() local
153 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture() local
173 ListenableFuture<String> future = immediateFailedFuture(exception); in testImmediateFailedFuture_cancellationException() local
193 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureBasic() local
199 ListenableFuture<String> future = CallerClass1.makeImmediateCancelledFuture(); in testImmediateCancelledFutureStack() local
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/auth/signing/ |
| D | AwsSigner.java | 27 CompletableFuture<HttpRequest> future = new CompletableFuture<HttpRequest>(); in signRequest() local
51 CompletableFuture<byte[]> future = new CompletableFuture<byte[]>(); in signChunk() local
73 CompletableFuture<AwsSigningResult> future = new CompletableFuture<AwsSigningResult>(); in sign() local
94 CompletableFuture<AwsSigningResult> future = new CompletableFuture<AwsSigningResult>(); in sign() local
118 CompletableFuture<AwsSigningResult> future = new CompletableFuture<AwsSigningResult>(); in sign() local
121 …erSignTrailingHeaders(HttpHeader.marshalHeadersForJni(headers), previousSignature, config, future); in sign() local
135 CompletableFuture<AwsSigningResult> future) throws CrtRuntimeException; in awsSignerSignRequest()
141 CompletableFuture<AwsSigningResult> future) throws CrtRuntimeException; in awsSignerSignChunk()
147 CompletableFuture<AwsSigningResult> future) throws CrtRuntimeException; in awsSignerSignTrailingHeaders()
|
| /external/google-cloud-java/google-cloud-examples/src/main/java/com/google/cloud/examples/logging/snippets/ |
| D | LoggingSnippets.java | 84 Future<Sink> future = logging.createAsync(sinkInfo); in createSinkAsync() local
119 Future<Sink> future = logging.updateAsync(sinkInfo); in updateSinkAsync() local
144 Future<Sink> future = logging.getSinkAsync(sinkName); in getSinkAsync() local
170 Future<AsyncPage<Sink>> future = logging.listSinksAsync(ListOption.pageSize(100)); in listSinksAsync() local
200 Future<Boolean> future = logging.deleteSinkAsync(sinkName); in deleteSinkAsync() local
232 Future<Boolean> future = logging.deleteLogAsync(logName); in deleteLogAsync() local
262 Future<AsyncPage<MonitoredResourceDescriptor>> future = in listMonitoredResourceDescriptorsAsync() local
293 Future<Metric> future = logging.createAsync(metricInfo); in createMetricAsync() local
324 Future<Metric> future = logging.updateAsync(metricInfo); in updateMetricAsync() local
349 Future<Metric> future = logging.getMetricAsync(metricName); in getMetricAsync() local
[all …]
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientHandlerTest.java | 291 ChannelFuture future = cancelStream(Status.CANCELLED); in cancelTwiceShouldSucceed() local
304 ChannelFuture future = cancelStream(Status.CANCELLED); in cancelTwiceDifferentReasons() local
313 ChannelFuture future in sendFrameShouldSucceed() local
325 ChannelFuture future in sendForUnknownStreamShouldFail() local
359 ChannelFuture future = enqueue(newCreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayNoErrorShouldRefuseLaterStreamId() local
367 ChannelFuture future = enqueue(newCreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayErrorShouldRefuseLaterStreamId() local
378 ChannelFuture future = enqueue(newCreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldNotAffectEarlyStreamId() local
388 ChannelFuture future = writeQueue().enqueue( in receivedGoAwayShouldNotAffectRacingQueuedStreamId() local
399 ChannelFuture future = writeQueue().enqueue( in receivedAbruptGoAwayShouldFailRacingQueuedStreamid() local
449 ChannelFuture future = enqueue(newCreateStreamCommand(grpcHeaders, streamTransportState)); in receivedResetWithRefuseCode() local
[all …]
|
| /external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/robotests/ |
| D | BothProfilesListenableFutureTest.java | 108 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_blockingMethod_blocks() local
120 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_nonblockingMethod_doesNotBlock() local
132 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_nonblockingMethod_doesCallback() local
184 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_isBound_becomesUnbound_callbackFires() local
197 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_profilesWithExceptionsAreNotIncludedInResults() local
209 ListenableFuture<Map<Profile, String>> future = in both_listenableFuture_connectionDropsDuringCall_resultContainsOnlyCurrentProfilesResult() local
227 ListenableFuture<Map<Profile, String>> future = in both_listenableFuture_doesNotTimeout() local
|
| D | BothProfilesManualListenableFutureTest.java | 110 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_isBound_blockingMethod_blocks() local
123 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_isBound_nonblockingMethod_doesNotBlock() local
136 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_isBound_nonblockingMethod_doesCallback() local
193 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_isBound_becomesUnbound_callbackFires() local
207 ListenableFuture<Map<Profile, Void>> future = in both_listenableFuture_manualConnection_profilesWithExceptionsAreNotIncludedInResults() local
220 ListenableFuture<Map<Profile, String>> future = in both_listenableFuture_manualConnection_connectionDropsDuringCall_resultContainsOnlyCurrentProfilesResult() local
|
| /external/sdk-platform-java/api-common-java/src/test/java/com/google/api/core/ |
| D | SettableApiFutureTest.java | 42 SettableApiFuture<Integer> future = SettableApiFuture.<Integer>create(); in testSet() local
52 SettableApiFuture<Integer> future = SettableApiFuture.<Integer>create(); in testCancel() local
62 SettableApiFuture<Integer> future = SettableApiFuture.<Integer>create(); in testException() local
70 SettableApiFuture<Integer> future = SettableApiFuture.<Integer>create(); in testListener() local
|
| /external/guava/guava-gwt/test-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/ |
| D | TestPlatform.java | 30 static void verifyGetOnPendingFuture(Future<?> future) { in verifyGetOnPendingFuture()
40 static void verifyTimedGetOnPendingFuture(Future<?> future) { in verifyTimedGetOnPendingFuture()
58 static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { in getDoneFromTimeoutOverload()
59 checkState(future.isDone(), "Future was expected to be done: %s", future); in getDoneFromTimeoutOverload() local
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 345 final ListenableFuture<? extends V> future; field in AbstractFuture.SetFuture
347 SetFuture(AbstractFuture<V> owner, ListenableFuture<? extends V> future) { in SetFuture()
845 protected boolean setFuture(ListenableFuture<? extends V> future) { in setFuture()
903 private static Object getFutureValue(ListenableFuture<?> future) { in getFutureValue()
983 private static <V extends @Nullable Object> V getUninterruptibly(Future<V> future) in getUninterruptibly()
1004 AbstractFuture<?> future = param; in complete() local
1323 AbstractFuture<?> future, @CheckForNull Waiter expect, @CheckForNull Waiter update); in casWaiters()
1327 AbstractFuture<?> future, @CheckForNull Listener expect, Listener update); in casListeners()
1330 abstract Waiter gasWaiters(AbstractFuture<?> future, Waiter update); in gasWaiters()
1333 abstract Listener gasListeners(AbstractFuture<?> future, Listener update); in gasListeners()
[all …]
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 345 final ListenableFuture<? extends V> future; field in AbstractFuture.SetFuture
347 SetFuture(AbstractFuture<V> owner, ListenableFuture<? extends V> future) { in SetFuture()
845 protected boolean setFuture(ListenableFuture<? extends V> future) { in setFuture()
903 private static Object getFutureValue(ListenableFuture<?> future) { in getFutureValue()
983 private static <V extends @Nullable Object> V getUninterruptibly(Future<V> future) in getUninterruptibly()
1004 AbstractFuture<?> future = param; in complete() local
1323 AbstractFuture<?> future, @CheckForNull Waiter expect, @CheckForNull Waiter update); in casWaiters()
1327 AbstractFuture<?> future, @CheckForNull Listener expect, Listener update); in casListeners()
1330 abstract Waiter gasWaiters(AbstractFuture<?> future, Waiter update); in gasWaiters()
1333 abstract Listener gasListeners(AbstractFuture<?> future, Listener update); in gasListeners()
[all …]
|