Home
last modified time | relevance | path

Searched refs:await (Results 1 – 25 of 288) sorted by relevance

12345678910>>...12

/external/python/cpython3/Lib/test/
Dtest_asyncgen.py136 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()
257 await awaitable()
259 await awaitable()
[all …]
Dtest_coroutines.py577 await bar()
602 await bar()
676 await gen()
708 await foo
732 await gen()
734 await gen()
747 return await coro
765 await nop()
768 await nop()
769 return await coro
[all …]
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DResponseHeadersTest.cs69 await context.WriteResponseHeadersAsync(headers); in ResponseHeadersAsync_UnaryCall()
74 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_UnaryCall()
80 Assert.AreEqual("PASS", await call.ResponseAsync); in ResponseHeadersAsync_UnaryCall()
88 await context.WriteResponseHeadersAsync(headers); in ResponseHeadersAsync_ClientStreamingCall()
93 await call.RequestStream.CompleteAsync(); in ResponseHeadersAsync_ClientStreamingCall()
94 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_ClientStreamingCall()
97 Assert.AreEqual("PASS", await call.ResponseAsync); in ResponseHeadersAsync_ClientStreamingCall()
105 await context.WriteResponseHeadersAsync(headers); in ResponseHeadersAsync_ServerStreamingCall()
106 await responseStream.WriteAsync("PASS"); in ResponseHeadersAsync_ServerStreamingCall()
110 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_ServerStreamingCall()
[all …]
DCallCancellationTest.cs65 await requestStream.ToListAsync(); in ClientStreamingCall_CancelAfterBegin()
72 await barrier.Task; // make sure the handler has started. in ClientStreamingCall_CancelAfterBegin()
78 await call.ResponseAsync; in ClientStreamingCall_CancelAfterBegin()
100 await cancelNotificationReceivedBarrier.Task; in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
102 var moveNextResult = await requestStream.MoveNext(); in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
110 await handlerStartedBarrier.Task; in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
115 await call.ResponseAsync; in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
122 Assert.AreEqual("SUCCESS", await successTcs.Task); in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
133 await moveNextTask; in ClientStreamingCall_CancelServerSideRead()
141 await call.ResponseAsync; in ClientStreamingCall_CancelServerSideRead()
[all …]
DMarshallingErrorsTest.cs95 await responseStream.WriteAsync("UNPARSEABLE_VALUE"); in ResponseParsingError_StreamingResponse()
96 await Task.Delay(10000); in ResponseParsingError_StreamingResponse()
100 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ResponseParsingError_StreamingResponse()
125 await requestStream.MoveNext(); in RequestParsingError_StreamingRequest()
135 await call.RequestStream.WriteAsync("UNPARSEABLE_VALUE"); in RequestParsingError_StreamingRequest()
137 Assert.AreEqual("RESPONSE", await call); in RequestParsingError_StreamingRequest()
149 …Assert.ThrowsAsync<IOException>(async () => await Calls.AsyncUnaryCall(helper.CreateUnaryCall(), "… in RequestSerializationError_AsyncUnary()
157 CollectionAssert.AreEqual(new[] { "A", "B" }, await requestStream.ToListAsync()); in RequestSerializationError_ClientStreaming()
161 await call.RequestStream.WriteAsync("A"); in RequestSerializationError_ClientStreaming()
162 …Assert.ThrowsAsync<IOException>(async () => await call.RequestStream.WriteAsync("UNSERIALIZABLE_VA… in RequestSerializationError_ClientStreaming()
[all …]
DCompressionTest.cs73 await requestStream.ToListAsync(); in WriteOptions_DuplexStreaming()
77 … await context.WriteResponseHeadersAsync(new Metadata { { "ascii-header", "abcdefg" } }); in WriteOptions_DuplexStreaming()
79 await responseStream.WriteAsync("X"); in WriteOptions_DuplexStreaming()
82 await responseStream.WriteAsync("Y"); in WriteOptions_DuplexStreaming()
85 await responseStream.WriteAsync("Z"); in WriteOptions_DuplexStreaming()
95 await call.RequestStream.WriteAsync("A"); in WriteOptions_DuplexStreaming()
98 await call.RequestStream.WriteAsync("B"); in WriteOptions_DuplexStreaming()
101 await call.RequestStream.WriteAsync("C"); in WriteOptions_DuplexStreaming()
103 await call.RequestStream.CompleteAsync(); in WriteOptions_DuplexStreaming()
105 await call.ResponseStream.ToListAsync(); in WriteOptions_DuplexStreaming()
[all …]
DContextPropagationTest.cs66 await Task.Delay(10); in PropagateCancellation()
80 await Calls.AsyncUnaryCall(helper.CreateUnaryCall(callOptions), "xyz"); in PropagateCancellation()
91 await readyToCancelTcs.Task; in PropagateCancellation()
96 await parentCall; in PropagateCancellation()
102 Assert.AreEqual("CHILD_CALL_CANCELLED", await successTcs.Task); in PropagateCancellation()
127 return await Calls.AsyncUnaryCall(helper.CreateUnaryCall(callOptions), "xyz"); in PropagateDeadline()
131 await call.RequestStream.CompleteAsync(); in PropagateDeadline()
132 Assert.AreEqual("PASS", await call); in PropagateDeadline()
149 return await Calls.AsyncUnaryCall(helper.CreateUnaryCall(callOptions), "xyz"); in SuppressDeadlinePropagation()
154 await call.RequestStream.CompleteAsync(); in SuppressDeadlinePropagation()
[all …]
DClientServerTest.cs67 Assert.AreEqual("ABC", await Calls.AsyncUnaryCall(helper.CreateUnaryCall(), "ABC")); in UnaryCall()
81 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerThrows()
97 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerThrowsRpcException()
117 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerThrowsRpcExceptionWithTrailers()
137 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerSetsStatus()
158 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerSetsStatusAndTrailers()
171 await requestStream.ForEachAsync((request) => in ClientStreamingCall()
176 await Task.Delay(100); in ClientStreamingCall()
181 await call.RequestStream.WriteAllAsync(new string[] { "A", "B", "C" }); in ClientStreamingCall()
182 Assert.AreEqual("ABC", await call.ResponseAsync); in ClientStreamingCall()
[all …]
DChannelTest.cs59 …Assert.ThrowsAsync(typeof(ArgumentException), async () => await channel.WaitForStateChangedAsync(C… in WaitForStateChangedAsync_InvalidArgument()
76 … Assert.ThrowsAsync(typeof(InvalidOperationException), async () => await channel.ShutdownAsync()); in Shutdown_AllowedOnlyOnce()
86 await shutdownTask; in ShutdownTokenCancelledAfterShutdown()
93 await channel.ShutdownAsync(); in StateIsShutdownAfterShutdown()
103 await stateChangedTask; in ShutdownFinishesWaitForStateChangedAsync()
104 await shutdownTask; in ShutdownFinishesWaitForStateChangedAsync()
111 await channel.ShutdownAsync(); in OperationsThrowAfterShutdown()
112 …Assert.ThrowsAsync(typeof(ObjectDisposedException), async () => await channel.WaitForStateChangedA… in OperationsThrowAfterShutdown()
114 … Assert.ThrowsAsync(typeof(TaskCanceledException), async () => await channel.ConnectAsync()); in OperationsThrowAfterShutdown()
DChannelConnectivityTest.cs61 …async () => await channel.WaitForStateChangedAsync(channel.State, DateTime.UtcNow.AddMilliseconds(… in Channel_WaitForStateChangedAsync()
64 await channel.ConnectAsync(DateTime.UtcNow.AddMilliseconds(5000)); in Channel_WaitForStateChangedAsync()
65 await stateChangedTask; in Channel_WaitForStateChangedAsync()
72 …Assert.IsFalse(await channel.TryWaitForStateChangedAsync(channel.State, DateTime.UtcNow.AddMillise… in Channel_TryWaitForStateChangedAsync()
75 await channel.ConnectAsync(DateTime.UtcNow.AddMilliseconds(5000)); in Channel_TryWaitForStateChangedAsync()
76 Assert.IsTrue(await stateChangedTask); in Channel_TryWaitForStateChangedAsync()
83 await channel.ConnectAsync(); in Channel_ConnectAsync()
86 await channel.ConnectAsync(DateTime.UtcNow.AddMilliseconds(1000)); in Channel_ConnectAsync()
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DInteropClient.cs96 var credentials = await CreateCredentialsAsync(); in Run()
107 await RunTestCaseAsync(channel, options); in Run()
108 await channel.ShutdownAsync(); in Run()
121 var googleCredential = await GoogleCredential.GetApplicationDefaultAsync(); in CreateCredentialsAsync()
128 var googleCredential = await GoogleCredential.GetApplicationDefaultAsync(); in CreateCredentialsAsync()
147 await RunClientStreamingAsync(client); in RunTestCaseAsync()
150 await RunServerStreamingAsync(client); in RunTestCaseAsync()
153 await RunPingPongAsync(client); in RunTestCaseAsync()
156 await RunEmptyStreamAsync(client); in RunTestCaseAsync()
165 await RunOAuth2AuthTokenAsync(client, options.OAuthScope); in RunTestCaseAsync()
[all …]
DWorkerServiceImpl.cs44 GrpcPreconditions.CheckState(await requestStream.MoveNext()); in RunServer()
48 await responseStream.WriteAsync(new ServerStatus in RunServer()
55 while (await requestStream.MoveNext()) in RunServer()
58 await responseStream.WriteAsync(new ServerStatus in RunServer()
63 await runner.StopAsync(); in RunServer()
68 GrpcPreconditions.CheckState(await requestStream.MoveNext()); in RunClient()
72 await responseStream.WriteAsync(new ClientStatus in RunClient()
77 while (await requestStream.MoveNext()) in RunClient()
80 await responseStream.WriteAsync(new ClientStatus in RunClient()
85 await runner.StopAsync(); in RunClient()
DStressTestClient.cs129 await Task.WhenAll(tasks); in Run()
133 await channel.ShutdownAsync(); in Run()
136 await metricsServer.ShutdownAsync(); in Run()
148 await RunTestCaseAsync(client, testCase); in RunBodyAsync()
167 await InteropClient.RunClientStreamingAsync(client); in RunTestCaseAsync()
170 await InteropClient.RunServerStreamingAsync(client); in RunTestCaseAsync()
173 await InteropClient.RunPingPongAsync(client); in RunTestCaseAsync()
176 await InteropClient.RunEmptyStreamAsync(client); in RunTestCaseAsync()
179 await InteropClient.RunCancelAfterBeginAsync(client); in RunTestCaseAsync()
182 await InteropClient.RunCancelAfterFirstResponseAsync(client); in RunTestCaseAsync()
[all …]
DInteropClientServerTest.cs83 await InteropClient.RunClientStreamingAsync(client); in ClientStreaming()
89 await InteropClient.RunServerStreamingAsync(client); in ServerStreaming()
95 await InteropClient.RunPingPongAsync(client); in PingPong()
101 await InteropClient.RunEmptyStreamAsync(client); in EmptyStream()
107 await InteropClient.RunCancelAfterBeginAsync(client); in CancelAfterBegin()
113 await InteropClient.RunCancelAfterFirstResponseAsync(client); in CancelAfterFirstResponse()
119 await InteropClient.RunTimeoutOnSleepingServerAsync(client); in TimeoutOnSleepingServer()
125 await InteropClient.RunCustomMetadataAsync(client); in CustomMetadata()
131 await InteropClient.RunStatusCodeAndMessageAsync(client); in StatusCodeAndMessage()
DTestServiceImpl.cs42 await EnsureEchoMetadataAsync(context); in UnaryCall()
51 await EnsureEchoMetadataAsync(context); in StreamingOutputCall()
57 await responseStream.WriteAsync(response); in StreamingOutputCall()
63 await EnsureEchoMetadataAsync(context); in StreamingInputCall()
66 await requestStream.ForEachAsync(request => in StreamingInputCall()
76 await EnsureEchoMetadataAsync(context); in FullDuplexCall()
78 await requestStream.ForEachAsync(async request => in FullDuplexCall()
84 await responseStream.WriteAsync(response); in FullDuplexCall()
104 await context.WriteResponseHeadersAsync(new Metadata { entry }); in EnsureEchoMetadataAsync()
DClientRunners.cs192 await runnerTask; in StopAsync()
196 await channel.ShutdownAsync(); in StopAsync()
242 await client.UnaryCallAsync(request); in RunUnaryAsync()
248 await timer.WaitForNextAsync(); in RunUnaryAsync()
263 await call.RequestStream.WriteAsync(request); in RunStreamingPingPongAsync()
264 await call.ResponseStream.MoveNext(); in RunStreamingPingPongAsync()
270 await timer.WaitForNextAsync(); in RunStreamingPingPongAsync()
274 await call.RequestStream.CompleteAsync(); in RunStreamingPingPongAsync()
275 Assert.IsFalse(await call.ResponseStream.MoveNext()); in RunStreamingPingPongAsync()
291 await call.RequestStream.WriteAsync(request); in RunGenericStreamingAsync()
[all …]
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractScheduledServiceTest.java77 service.runFirstBarrier.await(); in testFailOnExceptionFromRun()
78 service.runSecondBarrier.await(); in testFailOnExceptionFromRun()
107 service.runFirstBarrier.await(); in testFailOnExceptionFromShutDown()
109 service.runSecondBarrier.await(); in testFailOnExceptionFromShutDown()
123 service.runFirstBarrier.await(); in testRunOneIterationCalledMultipleTimes()
125 service.runSecondBarrier.await(); in testRunOneIterationCalledMultipleTimes()
127 service.runFirstBarrier.await(); in testRunOneIterationCalledMultipleTimes()
129 service.runSecondBarrier.await(); in testRunOneIterationCalledMultipleTimes()
139 service.runFirstBarrier.await(); in testExecutorOnlyCalledOnce()
141 service.runSecondBarrier.await(); in testExecutorOnlyCalledOnce()
[all …]
DListenableFutureTaskTest.java50 taskLatch.await();
92 runLatch.await(); in testListenerDoesNotRunUntilTaskCompletes()
101 assertTrue(listenerLatch.await(5, TimeUnit.SECONDS)); in testListenerDoesNotRunUntilTaskCompletes()
111 runLatch.await(); in testListenerCalledOnException()
121 assertTrue(listenerLatch.await(5, TimeUnit.SECONDS)); in testListenerCalledOnException()
133 listenerLatch.await(5, TimeUnit.SECONDS); in testListenerCalledOnCancelFromNotRunning()
143 runLatch.await(); in testListenerCalledOnCancelFromRunning()
152 listenerLatch.await(5, TimeUnit.SECONDS); in testListenerCalledOnCancelFromRunning()
/external/grpc-grpc/src/csharp/Grpc.Examples/
DMathExamples.cs35 DivReply result = await client.DivAsync(new DivArgs { Dividend = 4, Divisor = 5 }); in DivAsyncExample()
43 List<Num> result = await call.ResponseStream.ToListAsync(); in FibExample()
59 await call.RequestStream.WriteAllAsync(numbers); in SumExample()
60 Console.WriteLine("Sum Result: " + await call.ResponseAsync); in SumExample()
74 await call.RequestStream.WriteAllAsync(divArgsList); in DivManyExample()
75 … Console.WriteLine("DivMany Result: " + string.Join("|", await call.ResponseStream.ToListAsync())); in DivManyExample()
91 await sumCall.RequestStream.WriteAllAsync(numbers); in DependendRequestsExample()
92 sum = await sumCall.ResponseAsync; in DependendRequestsExample()
95 …DivReply result = await client.DivAsync(new DivArgs { Dividend = sum.Num_, Divisor = numbers.Count… in DependendRequestsExample()
106 DivReply result = await client.DivAsync(new DivArgs { Dividend = 5, Divisor = 0 }); in HandleErrorExample()
[all …]
/external/python/cpython3/Lib/test/test_asyncio/
Dtest_subprocess.py107 proc = await asyncio.create_subprocess_exec(
115 await proc.stdin.drain()
119 data = await proc.stdout.read()
120 exitcode = await proc.wait()
133 proc = await asyncio.create_subprocess_exec(
138 stdout, stderr = await proc.communicate(data)
203 line = await proc.stdout.readline()
207 returncode = await proc.wait()
231 await asyncio.sleep(0.5, loop=self.loop)
233 await proc.stdin.drain()
[all …]
Dtest_queues.py44 await asyncio.sleep(0.1, loop=loop)
57 await asyncio.sleep(0.1, loop=loop)
128 await q.put(i)
134 await asyncio.sleep(0.01, loop=loop)
141 await asyncio.sleep(0.01, loop=loop)
160 return await q.get()
193 res = await q.get()
200 await started.wait()
202 res = await queue_get_task
233 return await asyncio.wait_for(q.get(), 0.051, loop=loop)
[all …]
Dtest_sslproto.py252 await asyncio.sleep(0.5, loop=self.loop)
257 tr, proto = await self.loop.create_connection(
261 new_tr = await self.loop.start_tls(tr, proto, client_context)
263 self.assertEqual(await on_data, b'O')
265 await on_eof
332 await asyncio.sleep(0.5, loop=self.loop)
338 tr, proto = await self.loop.create_connection(
342 new_tr = await self.loop.start_tls(tr, proto, client_context)
344 self.assertEqual(await on_data1, b'O')
348 self.assertEqual(await on_data2, b'2')
[all …]
/external/python/cpython3/Doc/library/
Dasyncio-api-index.rst8 This page lists all high-level async/await enabled asyncio APIs.
15 await on multiple things with timeouts.
27 * - ``await`` :func:`sleep`
30 * - ``await`` :func:`gather`
33 * - ``await`` :func:`wait_for`
36 * - ``await`` :func:`shield`
39 * - ``await`` :func:`wait`
111 * - ``await`` :func:`create_subprocess_exec`
114 * - ``await`` :func:`create_subprocess_shell`
135 * - ``await`` :func:`open_connection`
[all …]
/external/grpc-grpc/src/csharp/Grpc.Reflection.Tests/
DReflectionClientServerTest.cs68 var response = await SingleRequestAsync(new ServerReflectionRequest in FileByFilename_NotFound()
78 var response = await SingleRequestAsync(new ServerReflectionRequest in FileByFilename()
89 var response = await SingleRequestAsync(new ServerReflectionRequest in FileContainingSymbol()
100 var response = await SingleRequestAsync(new ServerReflectionRequest in FileContainingSymbol_NotFound()
110 var response = await SingleRequestAsync(new ServerReflectionRequest in ListServices()
121 var response = await SingleRequestAsync(new ServerReflectionRequest in FileContainingExtension()
131 await call.RequestStream.WriteAsync(request); in SingleRequestAsync()
132 Assert.IsTrue(await call.ResponseStream.MoveNext()); in SingleRequestAsync()
135 await call.RequestStream.CompleteAsync(); in SingleRequestAsync()
136 Assert.IsFalse(await call.ResponseStream.MoveNext()); in SingleRequestAsync()
/external/grpc-grpc/src/csharp/Grpc.Core/Utils/
DAsyncStreamExtensions.cs36 while (await streamReader.MoveNext().ConfigureAwait(false))
38 await asyncAction(streamReader.Current).ConfigureAwait(false);
49 while (await streamReader.MoveNext().ConfigureAwait(false))
65 await streamWriter.WriteAsync(element).ConfigureAwait(false);
69 await streamWriter.CompleteAsync().ConfigureAwait(false);
81 await streamWriter.WriteAsync(element).ConfigureAwait(false);

12345678910>>...12