• Home
  • Raw
  • Download

Lines Matching refs:await

96             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()
168 await RunPerRpcCredsAsync(client, options.OAuthScope); in RunTestCaseAsync()
171 await RunCancelAfterBeginAsync(client); in RunTestCaseAsync()
174 await RunCancelAfterFirstResponseAsync(client); in RunTestCaseAsync()
177 await RunTimeoutOnSleepingServerAsync(client); in RunTestCaseAsync()
180 await RunCustomMetadataAsync(client); in RunTestCaseAsync()
183 await RunStatusCodeAndMessageAsync(client); in RunTestCaseAsync()
195 await RunClientCompressedStreamingAsync(client); in RunTestCaseAsync()
232 await call.RequestStream.WriteAllAsync(bodySizes); in RunClientStreamingAsync()
234 var response = await call.ResponseAsync; in RunClientStreamingAsync()
253 var responseList = await call.ResponseStream.ToListAsync(); in RunServerStreamingAsync()
265 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
271 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
274 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
280 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
283 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
289 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
292 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
298 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
301 await call.RequestStream.CompleteAsync(); in RunPingPongAsync()
303 Assert.IsFalse(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
313 await call.RequestStream.CompleteAsync(); in RunEmptyStreamAsync()
315 var responseList = await call.ResponseStream.ToListAsync(); in RunEmptyStreamAsync()
365 …ITokenAccess credential = (await GoogleCredential.GetApplicationDefaultAsync()).CreateScoped(new[]… in RunOAuth2AuthTokenAsync()
366 string oauth2Token = await credential.GetAccessTokenForRequestAsync(); in RunOAuth2AuthTokenAsync()
386 ITokenAccess googleCredential = await GoogleCredential.GetApplicationDefaultAsync(); in RunPerRpcCredsAsync()
408 await Task.Delay(1000); in RunCancelAfterBeginAsync()
411 var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseAsync); in RunCancelAfterBeginAsync()
424 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunCancelAfterFirstResponseAsync()
430 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunCancelAfterFirstResponseAsync()
438 await call.ResponseStream.MoveNext(); in RunCancelAfterFirstResponseAsync()
458await call.RequestStream.WriteAsync(new StreamingOutputCallRequest { Payload = CreateZerosPayload(… in RunTimeoutOnSleepingServerAsync()
471 await call.ResponseStream.MoveNext(); in RunTimeoutOnSleepingServerAsync()
495 await call.ResponseAsync; in RunCustomMetadataAsync()
497 var responseHeaders = await call.ResponseHeadersAsync; in RunCustomMetadataAsync()
514 await call.RequestStream.WriteAsync(request); in RunCustomMetadataAsync()
515 await call.RequestStream.CompleteAsync(); in RunCustomMetadataAsync()
516 await call.ResponseStream.ToListAsync(); in RunCustomMetadataAsync()
518 var responseHeaders = await call.ResponseHeadersAsync; in RunCustomMetadataAsync()
551 await call.RequestStream.WriteAsync(request); in RunStatusCodeAndMessageAsync()
552 await call.RequestStream.CompleteAsync(); in RunStatusCodeAndMessageAsync()
557 await call.ResponseStream.ToListAsync(); in RunStatusCodeAndMessageAsync()
636 await probeCall.RequestStream.WriteAsync(new StreamingInputCallRequest in RunClientCompressedStreamingAsync()
646 await probeCall; in RunClientCompressedStreamingAsync()
655 await call.RequestStream.WriteAsync(new StreamingInputCallRequest in RunClientCompressedStreamingAsync()
665 await call.RequestStream.WriteAsync(new StreamingInputCallRequest in RunClientCompressedStreamingAsync()
673 await call.RequestStream.CompleteAsync(); in RunClientCompressedStreamingAsync()
675 var response = await call.ResponseAsync; in RunClientCompressedStreamingAsync()