| /cts/tests/tests/assist/common/src/android/assist/common/ |
| AutoResetLatch.java | 23 * A [CountDownLatch] that resets itself to [mCount] after every await call.
39 public void await() throws InterruptedException { method in class:AutoResetLatch
41 mLatch.await();
47 public boolean await(long timeout, TimeUnit unit) throws InterruptedException { method in class:AutoResetLatch
49 return mLatch.await(timeout, unit);
|
| /external/python/cpython3/Lib/test/ |
| test_asyncgen.py | 51 await abc
68 await abc
136 await awaitable()
139 await awaitable()
141 await awaitable()
148 await awaitable()
150 await awaitable()
174 await awaitable()
176 await awaitable(throw=True)
184 await awaitable(
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| AbstractScheduledServiceTest.java | 77 service.runFirstBarrier.await();
78 service.runSecondBarrier.await();
107 service.runFirstBarrier.await();
109 service.runSecondBarrier.await();
123 service.runFirstBarrier.await();
125 service.runSecondBarrier.await();
127 service.runFirstBarrier.await();
129 service.runSecondBarrier.await();
139 service.runFirstBarrier.await();
141 service.runSecondBarrier.await();
[all...] |
| ListenableFutureTaskTest.java | 50 taskLatch.await();
92 runLatch.await();
101 assertTrue(listenerLatch.await(5, TimeUnit.SECONDS));
111 runLatch.await();
121 assertTrue(listenerLatch.await(5, TimeUnit.SECONDS));
133 listenerLatch.await(5, TimeUnit.SECONDS);
143 runLatch.await();
152 listenerLatch.await(5, TimeUnit.SECONDS);
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| ResponseHeadersTest.cs | 69 await context.WriteResponseHeadersAsync(headers);
74 var responseHeaders = await call.ResponseHeadersAsync;
80 Assert.AreEqual("PASS", await call.ResponseAsync);
88 await context.WriteResponseHeadersAsync(headers);
93 await call.RequestStream.CompleteAsync();
94 var responseHeaders = await call.ResponseHeadersAsync;
97 Assert.AreEqual("PASS", await call.ResponseAsync);
105 await context.WriteResponseHeadersAsync(headers);
106 await responseStream.WriteAsync("PASS");
110 var responseHeaders = await call.ResponseHeadersAsync
[all...] |
| CompressionTest.cs | 73 await requestStream.ToListAsync();
77 await context.WriteResponseHeadersAsync(new Metadata { { "ascii-header", "abcdefg" } });
79 await responseStream.WriteAsync("X");
82 await responseStream.WriteAsync("Y");
85 await responseStream.WriteAsync("Z");
95 await call.RequestStream.WriteAsync("A");
98 await call.RequestStream.WriteAsync("B");
101 await call.RequestStream.WriteAsync("C");
103 await call.RequestStream.CompleteAsync();
105 await call.ResponseStream.ToListAsync()
[all...] |
| ChannelConnectivityTest.cs | 61 async () => await channel.WaitForStateChangedAsync(channel.State, DateTime.UtcNow.AddMilliseconds(0)));
64 await channel.ConnectAsync(DateTime.UtcNow.AddMilliseconds(5000));
65 await stateChangedTask;
72 Assert.IsFalse(await channel.TryWaitForStateChangedAsync(channel.State, DateTime.UtcNow.AddMilliseconds(0)));
75 await channel.ConnectAsync(DateTime.UtcNow.AddMilliseconds(5000));
76 Assert.IsTrue(await stateChangedTask);
83 await channel.ConnectAsync();
86 await channel.ConnectAsync(DateTime.UtcNow.AddMilliseconds(1000));
|
| /external/perfetto/infra/perfetto-ci.appspot.com/static/ |
| service_worker.js | 28 const cachedResponse = await caches.match(event.request);
34 const response = await fetch(event.request);
40 const json = await response.clone().json();
|
| /art/test/170-interface-init/src/ |
| Main.java | 36 second.await();
44 first.await();
|
| /cts/hostsidetests/jvmti/base/app/src/art/ |
| CtsMain.java | 38 if (!sStartWaiter.await(15, TimeUnit.SECONDS)) {
|
| /cts/tests/app/src/android/app/cts/ |
| NewDocumentTest.java | 42 receiver.await();
47 receiver.await();
58 void await() throws InterruptedException { method in class:NewDocumentTest.Receiver
61 latch.await(TIMEOUT_MS, TimeUnit.MILLISECONDS));
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| WorkerServiceImpl.cs | 44 GrpcPreconditions.CheckState(await requestStream.MoveNext());
48 await responseStream.WriteAsync(new ServerStatus
55 while (await requestStream.MoveNext())
58 await responseStream.WriteAsync(new ServerStatus
63 await runner.StopAsync();
68 GrpcPreconditions.CheckState(await requestStream.MoveNext());
72 await responseStream.WriteAsync(new ClientStatus
77 while (await requestStream.MoveNext())
80 await responseStream.WriteAsync(new ClientStatus
85 await runner.StopAsync()
[all...] |
| InteropClientServerTest.cs | 83 await InteropClient.RunClientStreamingAsync(client);
89 await InteropClient.RunServerStreamingAsync(client);
95 await InteropClient.RunPingPongAsync(client);
101 await InteropClient.RunEmptyStreamAsync(client);
107 await InteropClient.RunCancelAfterBeginAsync(client);
113 await InteropClient.RunCancelAfterFirstResponseAsync(client);
119 await InteropClient.RunTimeoutOnSleepingServerAsync(client);
125 await InteropClient.RunCustomMetadataAsync(client);
131 await InteropClient.RunStatusCodeAndMessageAsync(client);
|
| /external/skia/tools/lottiecap/ |
| lottiecap.js | 126 await new Promise(resolve => setTimeout(() => resolve(), ms));
137 browser = await puppeteer.launch({
142 browser = await puppeteer.launch();
145 const page = await browser.newPage();
150 await page.goto(targetURL, {
157 await page.waitForFunction('window._tileCount === 25', {
163 await browser.close();
176 let result = await page.screenshot({
195 await fetch(options.post_to, {
208 await browser.close()
[all...] |
| /external/skqp/tools/lottiecap/ |
| lottiecap.js | 126 await new Promise(resolve => setTimeout(() => resolve(), ms));
137 browser = await puppeteer.launch({
142 browser = await puppeteer.launch();
145 const page = await browser.newPage();
150 await page.goto(targetURL, {
157 await page.waitForFunction('window._tileCount === 25', {
163 await browser.close();
176 let result = await page.screenshot({
195 await fetch(options.post_to, {
208 await browser.close()
[all...] |
| /cts/tests/tests/location/src/android/location/cts/ |
| GnssLocationRateChangeTest.java | 46 // Using separate listeners, so the await trigger for the after-rate-changes listener is
79 mLocationListenerMain.await());
90 mLocationListenerAfterRateChanges.await());
109 mLocationListenerMain.await());
121 mLocationListenerAfterRateChanges.await());
140 mLocationListenerMain.await());
160 mLocationListenerAfterRateChanges.await());
|
| /external/grpc-grpc/src/csharp/Grpc.Examples/ |
| MathExamples.cs | 35 DivReply result = await client.DivAsync(new DivArgs { Dividend = 4, Divisor = 5 });
43 List<Num> result = await call.ResponseStream.ToListAsync();
59 await call.RequestStream.WriteAllAsync(numbers);
60 Console.WriteLine("Sum Result: " + await call.ResponseAsync);
74 await call.RequestStream.WriteAllAsync(divArgsList);
75 Console.WriteLine("DivMany Result: " + string.Join("|", await call.ResponseStream.ToListAsync()));
91 await sumCall.RequestStream.WriteAllAsync(numbers);
92 sum = await sumCall.ResponseAsync;
95 DivReply result = await client.DivAsync(new DivArgs { Dividend = sum.Num_, Divisor = numbers.Count });
106 DivReply result = await client.DivAsync(new DivArgs { Dividend = 5, Divisor = 0 })
[all...] |
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| TestStreamTracer.java | 37 void await() throws InterruptedException; method in interface:TestStreamTracer
42 boolean await(long timeout, TimeUnit timeUnit) throws InterruptedException; method in interface:TestStreamTracer
101 public void await() throws InterruptedException { method in class:TestStreamTracer.TestBaseStreamTracer
102 streamClosed.await();
106 public boolean await(long timeout, TimeUnit timeUnit) throws InterruptedException { method in class:TestStreamTracer.TestBaseStreamTracer
107 return streamClosed.await(timeout, timeUnit);
|
| TestServerStreamTracer.java | 33 public void await() throws InterruptedException { method in class:TestServerStreamTracer
34 delegate.await();
38 public boolean await(long timeout, TimeUnit timeUnit) throws InterruptedException { method in class:TestServerStreamTracer
39 return delegate.await(timeout, timeUnit);
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| Ping.java | 55 latch.await();
65 if (latch.await(timeout, unit)) {
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| Ping.java | 57 latch.await();
67 if (latch.await(timeout, unit)) {
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_context.py | 13 await asyncio.sleep(t)
18 r1, r2 = await asyncio.gather(
|
| /external/sl4a/Utils/src/com/googlecode/android_scripting/future/ |
| FutureResult.java | 44 mLatch.await();
50 mLatch.await(timeout, unit);
|
| /cts/tests/accessibilityservice/src/android/accessibilityservice/cts/utils/ |
| AsyncUtils.java | 35 public static <T> T await(Future<T> f) { method in class:AsyncUtils
36 return await(f, DEFAULT_TIMEOUT_MS, MILLISECONDS);
39 public static <T> T await(Future<T> f, long time, TimeUnit timeUnit) { method in class:AsyncUtils
52 return assertThrows(() -> await(f, time, timeUnit));
|
| /art/test/033-class-init-deadlock/src/ |
| Main.java | 40 try { barrier.await(); } catch (Exception e) { System.out.println(e); }
56 try { Main.barrier.await(); } catch (Exception e) { System.out.println(e); }
66 try { Main.barrier.await(); } catch (Exception e) { System.out.println(e); }
|
