Searched refs:CompleteAsync (Results 1 – 15 of 15) sorted by relevance
76 await call.RequestStream.CompleteAsync(); in HalfcloseAfterFullclose_ClientStreamingCall()79 …rowsAsync(typeof(InvalidOperationException), async () => await call.RequestStream.CompleteAsync()); in HalfcloseAfterFullclose_ClientStreamingCall()
131 await call.RequestStream.CompleteAsync(); in PropagateDeadline()154 await call.RequestStream.CompleteAsync(); in SuppressDeadlinePropagation()
103 await call.RequestStream.CompleteAsync(); in WriteOptions_DuplexStreaming()
164 await call.RequestStream.CompleteAsync(); in RequestSerializationError_ClientStreaming()
93 await call.RequestStream.CompleteAsync(); in ResponseHeadersAsync_ClientStreamingCall()
199 public Task CompleteAsync() in CompleteAsync() method in Grpc.Core.Interceptors.Tests.ClientInterceptorTest.WrappedClientStreamWriter203 return writer.CompleteAsync().ContinueWith(x => onResponseStreamEnd()); in CompleteAsync()205 return writer.CompleteAsync(); in CompleteAsync()
36 Task CompleteAsync(); in CompleteAsync() method
130 await call.RequestStream.CompleteAsync(); in RecordRoute()183 await call.RequestStream.CompleteAsync(); in RouteChat()
304 await call.RequestStream.CompleteAsync(); in RunPingPongAsync()316 await call.RequestStream.CompleteAsync(); in RunEmptyStreamAsync()517 await call.RequestStream.CompleteAsync(); in RunCustomMetadataAsync()554 await call.RequestStream.CompleteAsync(); in RunStatusCodeAndMessageAsync()702 await call.RequestStream.CompleteAsync(); in RunClientCompressedStreamingAsync()
274 await call.RequestStream.CompleteAsync(); in RunStreamingPingPongAsync()302 await call.RequestStream.CompleteAsync(); in RunGenericStreamingAsync()
257 await call.RequestStream.CompleteAsync(); in CheckAuthContextIsPopulated()
41 public Task CompleteAsync() in CompleteAsync() method in Grpc.Core.Internal.ClientRequestStream
195 var completeTask = requestStream.CompleteAsync(); in ClientStreaming_MoreRequests_Success()321 requestStream.CompleteAsync(); in ClientStreaming_WriteAfterCompleteThrowsInvalidOperationException()347 Assert.DoesNotThrowAsync(async () => await requestStream.CompleteAsync()); in ClientStreaming_CompleteAfterReceivingStatusSucceeds()481 var writeTask1 = requestStream.CompleteAsync(); in DuplexStreaming_NoRequestNoResponse_Success()523 Assert.DoesNotThrowAsync(async () => await requestStream.CompleteAsync()); in DuplexStreaming_CompleteAfterReceivingStatusSuceeds()
69 await streamWriter.CompleteAsync().ConfigureAwait(false);
135 await call.RequestStream.CompleteAsync(); in SingleRequestAsync()