Searched refs:future2 (Results 1 – 9 of 9) sorted by relevance
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | FuturesTest.java | 118 ListenableFuture<String> future2 = Futures.immediateFuture(DATA2); in testMultipleImmediateFutures() local
122 assertSame(DATA2, future2.get(0L, TimeUnit.MILLISECONDS)); in testMultipleImmediateFutures()
174 CheckedFuture<String, MyException> future2 = Futures.immediateCheckedFuture( in testMultipleImmediateCheckedFutures() local
180 assertSame(DATA2, future2.get(0L, TimeUnit.MILLISECONDS)); in testMultipleImmediateCheckedFutures()
181 assertSame(DATA2, future2.checkedGet(0L, TimeUnit.MILLISECONDS)); in testMultipleImmediateCheckedFutures()
820 SettableFuture<String> future2 = SettableFuture.create();
824 Futures.allAsList(future1, future2, future3);
834 future2.set(DATA2);
870 SettableFuture<String> future2 = SettableFuture.create();
873 Futures.allAsList(future1, future2);
[all …]
|
| /external/python/futures/ |
| D | test_futures.py | 300 future2 = self.executor.submit(time.sleep, 1.5)
303 [CANCELLED_FUTURE, future1, future2],
307 self.assertEqual(set([CANCELLED_FUTURE, future2]), not_done)
323 future2 = self.executor.submit(sleep_and_raise, 1.5)
327 [future1, future2, future3],
330 self.assertEqual(set([future1, future2]), finished)
335 future2 = self.executor.submit(time.sleep, 1.5)
341 future1, future2],
347 self.assertEqual(set([CANCELLED_FUTURE, future2]), pending)
361 future2 = self.executor.submit(mul, 2, 21)
[all …]
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 447 future2 = self.executor.submit(time.sleep, 1.5)
450 [CANCELLED_FUTURE, future1, future2],
454 self.assertEqual(set([CANCELLED_FUTURE, future2]), not_done)
470 future2 = self.executor.submit(sleep_and_raise, 1.5)
474 [future1, future2, future3],
477 self.assertEqual(set([future1, future2]), finished)
482 future2 = self.executor.submit(time.sleep, 1.5)
488 future1, future2],
494 self.assertEqual(set([CANCELLED_FUTURE, future2]), pending)
508 future2 = self.executor.submit(mul, 2, 21)
[all …]
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_proactor_events.py | 850 future2 = mock.Mock()
853 sock2.fileno(): future2
861 self.assertFalse(future2.cancel.called)
|
| /external/conscrypt/repackaged/openjdk-integ-tests/src/test/java/com/android/org/conscrypt/javax/net/ssl/ |
| D | SSLSocketVersionCompatibilityTest.java | 269 final Future<byte[]> future2 = runAsync(new SSLServerSessionIdCallable(server2)); in test_SSLSocket_confirmSessionReuse() local
274 final byte[] serverSessionId2 = future2.get(); in test_SSLSocket_confirmSessionReuse()
|
| /external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/javax/net/ssl/ |
| D | SSLSocketVersionCompatibilityTest.java | 267 final Future<byte[]> future2 = runAsync(new SSLServerSessionIdCallable(server2)); in test_SSLSocket_confirmSessionReuse() local
272 final byte[] serverSessionId2 = future2.get(); in test_SSLSocket_confirmSessionReuse()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ManagedChannelImplTest.java | 2789 ListenableFuture<Void> future2 = ClientCalls.futureUnaryCall(call2, null); in badServiceConfigIsRecoverable() local
2795 future2.get(); in badServiceConfigIsRecoverable()
|
| /external/protobuf/php/ext/google/protobuf/ |
| D | upb.h | 5232 void *future2;
5294 void *future2;
|
| /external/protobuf/ruby/ext/google/protobuf_c/ |
| D | upb.h | 645 void *future2; variable
|