Home
last modified time | relevance | path

Searched defs:future (Results 1 – 25 of 134) sorted by relevance

123456

/external/dagger2/producers/src/test/java/dagger/producers/internal/
DProducersTest.java40 ListenableFuture<String> future = Futures.immediateFuture("monkey"); in createFutureProduced_success() local
47 ListenableFuture<String> future = Futures.immediateFailedFuture(new RuntimeException("monkey")); in createFutureProduced_failure() local
54 ListenableFuture<String> future = SettableFuture.create(); in createFutureProduced_cancelPropagatesBackwards() local
62 ListenableFuture<String> future = SettableFuture.create(); in createFutureProduced_cancelDoesNotPropagateForwards() local
81 ListenableFuture<String> future = Futures.immediateFuture("monkey"); in createFutureSingletonSet_success() local
88 ListenableFuture<String> future = Futures.immediateFailedFuture(new RuntimeException("monkey")); in createFutureSingletonSet_failure() local
DSetProducerTest.java49 ListenableFuture<Set<Integer>> future = producer.get(); in delegateSetNpe() local
63 ListenableFuture<Set<Integer>> future = producer.get(); in delegateElementNpe() local
DAbstractProducerTest.java95 ListenableFuture<Integer> future = producer.get(); in monitor_success() local
109 ListenableFuture<Integer> future = producer.get(); in monitor_failure() local
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractFutureTest.java48 AbstractFuture<String> future = new AbstractFuture<String>() { in testException() local
68 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneNoInterrupt() local
83 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneInterrupt() local
98 AbstractFuture<String> future = new AbstractFuture<String>() { in testCancel_done() local
111 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testCompletionFinishesWithDone() local
181 AbstractFuture<String> future) throws InterruptedException { in getExpectingExecutionException()
DAsyncSettableFutureTest.java38 AsyncSettableFuture<Integer> future = AsyncSettableFuture.create(); in testCreate() local
45 AsyncSettableFuture<Integer> future = AsyncSettableFuture.create(); in testSetValue() local
59 AsyncSettableFuture<Object> future = AsyncSettableFuture.create(); in testSetException() local
79 AsyncSettableFuture<String> future = AsyncSettableFuture.create(); in testSetFuture() local
101 AsyncSettableFuture<Foo> future = AsyncSettableFuture.create(); in testSetFuture_genericsHierarchy() local
DFuturesTest.java110 ListenableFuture<String> future = Futures.immediateFuture(DATA1); in testImmediateFuture() local
127 ListenableFuture<String> future = in testImmediateFailedFuture() local
141 ListenableFuture<String> future = in testImmediateFailedFuture_cancellationException() local
155 ListenableFuture<String> future = in testImmediateCancelledFuture() local
163 CheckedFuture<String, MyException> future = Futures.immediateCheckedFuture( in testImmediateCheckedFuture() local
186 CheckedFuture<String, MyException> future = in testImmediateFailedCheckedFuture() local
220 ListenableFuture<FooChild> future = Futures.immediateFuture(null); in testTransform_genericsHierarchy() local
DListenableFutureTester.java42 private final ListenableFuture<?> future; field in ListenableFutureTester
45 public ListenableFutureTester(ListenableFuture<?> future) { in ListenableFutureTester()
DMoreExecutorsTest.java124 ListenableFuture<?> future = executor.submit(incrementTask); in testDirectExecutorServiceServiceInThreadExecution() local
158 Future<Integer> future = futures.get(i); in testDirectExecutorServiceInvokeAll() local
309 ListenableFuture<?> future = in testListeningDecorator_scheduleSuccess() local
327 ListenableFuture<?> future = in testListeningDecorator_scheduleFailure() local
338 ListenableFuture<?> future; in testListeningDecorator_schedulePeriodic() local
357 ListenableFuture<?> future; in testListeningDecorator_cancelled() local
405 private static void assertExecutionException(Future<?> future, Exception expectedCause) in assertExecutionException()
497 private static void assertListenerRunImmediately(ListenableFuture<?> future) { in assertListenerRunImmediately()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientHandlerTest.java261 ChannelFuture future = cancelStream(Status.CANCELLED); in cancelTwiceShouldSucceed() local
274 ChannelFuture future = cancelStream(Status.CANCELLED); in cancelTwiceDifferentReasons() local
283 ChannelFuture future in sendFrameShouldSucceed() local
295 ChannelFuture future in sendForUnknownStreamShouldFail() local
331 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldCancelBufferedStream() local
342 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldRefuseLaterStreamId() local
350 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldNotAffectEarlyStreamId() local
361 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedResetWithRefuseCode() local
369 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedResetWithCanceCode() local
392 ChannelFuture future = enqueue(new CreateStreamCommand(grpcHeaders, streamTransportState)); in receivedGoAwayShouldFailUnknownBufferedStreams() local
[all …]
/external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/
DTestingExecutorsTest.java48 ScheduledFuture<?> future = TestingExecutors.noOpScheduledExecutor().schedule( in testNoOpScheduledExecutor() local
75 Future<Boolean> future = futureList.get(0); in testNoOpScheduledExecutorInvokeAll() local
94 Future<Integer> future = TestingExecutors.sameThreadScheduledExecutor().schedule( in testSameThreadScheduledExecutor() local
107 Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable); in testSameThreadScheduledExecutorWithException() local
/external/python/cpython3/Lib/concurrent/futures/
D_base.py62 def add_result(self, future): argument
65 def add_exception(self, future): argument
68 def add_cancelled(self, future): argument
78 def add_result(self, future): argument
83 def add_exception(self, future): argument
88 def add_cancelled(self, future): argument
96 def add_result(self, future): argument
100 def add_exception(self, future): argument
104 def add_cancelled(self, future): argument
123 def add_result(self, future): argument
[all …]
/external/python/futures/concurrent/futures/
D_base.py64 def add_result(self, future): argument
67 def add_exception(self, future): argument
70 def add_cancelled(self, future): argument
80 def add_result(self, future): argument
85 def add_exception(self, future): argument
90 def add_cancelled(self, future): argument
98 def add_result(self, future): argument
102 def add_exception(self, future): argument
106 def add_cancelled(self, future): argument
125 def add_result(self, future): argument
[all …]
/external/robolectric-shadows/robolectric/src/test/java/org/robolectric/android/util/concurrent/
DRoboExecutorServiceTest.java48 Future<String> future = executorService.submit(runnable, "foo"); in submitRunnable_shouldRunStuffOnBackgroundThread() local
62 Future<String> future = executorService.submit(new Callable<String>() { in submitCallable_shouldRunStuffOnBackgroundThread() local
113 Future<String> future = executorService.submit(runnable, "foo"); in whenGettingFutureValue_FutureRunnableIsExecuted() local
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
DAbstractCheckedFutureTest.java70 final CheckedFuture<Boolean, ?> future = in testCheckedGetThrowsApplicationExceptionOnCancellation() local
97 final CheckedFuture<Boolean, ?> future = in testCheckedGetThrowsApplicationExceptionOnInterruption() local
134 final CheckedFuture<Boolean, ?> future = in testCheckedGetThrowsApplicationExceptionOnError() local
DMockFutureListener.java40 private final ListenableFuture<?> future; field in MockFutureListener
42 public MockFutureListener(ListenableFuture<?> future) { in MockFutureListener()
/external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/
DShadowAccountManagerTest.java330 AccountManagerFuture<Boolean> future = am.removeAccount(wrongAccount, null, null); in removeAccount_doesNotRemoveAccountOfDifferentName() local
341 …AccountManagerFuture<Boolean> future = am.removeAccount(account, testAccountManagerCallback, null); in removeAccount_does() local
583 …AccountManagerFuture<Bundle> future = am.addAccount("unknown_account_type", "auth_token_type", nul… in addAccount_noAuthenticatorDefined() local
661 AccountManagerFuture<Bundle> future = am.getAuthToken(account, in getAuthToken_withActivity_returnsCorrectToken() local
683 AccountManagerFuture<Bundle> future = am.getAuthToken(account, in getAuthToken_withActivity_returnsAuthIntent() local
710 AccountManagerFuture<Bundle> future = in getAuthToken_withNotifyAuthFailureSetToFalse_returnsCorrectToken() local
736 AccountManagerFuture<Bundle> future = in getAuthToken_withNotifyAuthFailureSetToFalse_returnsAuthIntent() local
763 …AccountManagerFuture<Boolean> future = am.hasFeatures(account, new String[] { "FEATURE_1", "FEATUR… in getHasFeatures_returnsTrueWhenAllFeaturesSatisfied() local
778 …AccountManagerFuture<Boolean> future = am.hasFeatures(account, new String[] { "FEATURE_1", "FEATUR… in getHasFeatures_returnsFalseWhenAllFeaturesNotSatisfied() local
803 …AccountManagerFuture<Account[]> future = am.getAccountsByTypeAndFeatures("google.com", new String[… in getAccountsByTypeAndFeatures() local
[all …]
/external/conscrypt/repackaged/openjdk-integ-tests/src/test/java/com/android/org/conscrypt/javax/net/ssl/
DSSLSocketVersionCompatibilityTest.java198 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_startHandshake() local
293 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_NoEnabledCipherSuites_Failure() local
327 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_startHandshake_noKeyStore() local
361 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_startHandshake_noClientCertificate() local
384 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_HandshakeCompletedListener() local
492 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_HandshakeCompletedListener_RuntimeException() local
570 Future<IOException> future = runAsync(new Callable<IOException>() { in test_SSLSocket_setUseClientMode() local
612 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_clientAuth() local
684 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_clientAuth_bogusAlias() local
781 Future<Void> future = runAsync(new Callable<Void>() { in run_SSLSocket_clientAuth_OpaqueKey() local
[all …]
/external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/javax/net/ssl/
DSSLSocketVersionCompatibilityTest.java196 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_startHandshake() local
291 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_NoEnabledCipherSuites_Failure() local
325 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_startHandshake_noKeyStore() local
359 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_startHandshake_noClientCertificate() local
382 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_HandshakeCompletedListener() local
490 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_HandshakeCompletedListener_RuntimeException() local
568 Future<IOException> future = runAsync(new Callable<IOException>() { in test_SSLSocket_setUseClientMode() local
610 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_clientAuth() local
682 Future<Void> future = runAsync(new Callable<Void>() { in test_SSLSocket_clientAuth_bogusAlias() local
779 Future<Void> future = runAsync(new Callable<Void>() { in run_SSLSocket_clientAuth_OpaqueKey() local
[all …]
/external/guava/guava-testlib/test/com/google/common/testing/
DGcFinalizationTest.java53 final SettableFuture<Void> future = SettableFuture.create(); in testAwaitDone_Future() local
64 final SettableFuture<Void> future = SettableFuture.create(); in testAwaitDone_Future_Cancel() local
144 final SettableFuture<Void> future = SettableFuture.create(); in testAwaitDone_Future_Interrupted_Interrupted() local
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DFakeClockTest.java48 ScheduledFuture<?> future = fakeClock.getScheduledExecutorService() in testScheduledExecutorService_isDone() local
61 ScheduledFuture<?> future = fakeClock.getScheduledExecutorService() in testScheduledExecutorService_cancel() local
74 ScheduledFuture<?> future = fakeClock.getScheduledExecutorService() in testScheduledExecutorService_getDelay() local
/external/guava/guava/src/com/google/common/util/concurrent/
DJdkFutureAdapters.java59 Future<V> future) { in listenInPoolThread()
91 Future<V> future, Executor executor) { in listenInPoolThread()
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DClientCallsTest.java156 ListenableFuture<String> future = ClientCalls.futureUnaryCall(call, req); in unaryFutureCallSuccess() local
176 ListenableFuture<String> future = ClientCalls.futureUnaryCall(call, req); in unaryFutureCallFailed() local
209 ListenableFuture<String> future = ClientCalls.futureUnaryCall(call, req); in unaryFutureCallCancelled() local
491 final SettableFuture<Void> future = SettableFuture.create(); in inprocessTransportOutboundFlowControl() local
/external/v4l2_codec2/
DC2VDAAdaptorProxy.cpp52 auto future = ::arc::Future<bool>::make_shared(mRelay); in establishChannel() local
59 void C2VDAAdaptorProxy::establishChannelOnMojoThread(std::shared_ptr<::arc::Future<bool>> future) { in establishChannelOnMojoThread()
73 void C2VDAAdaptorProxy::onVersionReady(std::shared_ptr<::arc::Future<bool>> future, uint32_t versio… in onVersionReady()
186 auto future = ::arc::Future<::arc::mojom::VideoDecodeAccelerator::Result>::make_shared(mRelay); in initialize() local
/external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/duration/
DPeriod.java148 public Period inFuture(boolean future) { in inFuture()
295 private Period(int limit, boolean future, float count, TimeUnit unit) { in Period()
347 private Period setFuture(boolean future) { in setFuture()
/external/icu/android_icu4j/src/main/java/android/icu/impl/duration/
DPeriod.java150 public Period inFuture(boolean future) { in inFuture()
297 private Period(int limit, boolean future, float count, TimeUnit unit) { in Period()
349 private Period setFuture(boolean future) { in setFuture()

123456