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()
301 await call.RequestStream.CompleteAsync(); in RunPingPongAsync()313 await call.RequestStream.CompleteAsync(); in RunEmptyStreamAsync()515 await call.RequestStream.CompleteAsync(); in RunCustomMetadataAsync()552 await call.RequestStream.CompleteAsync(); in RunStatusCodeAndMessageAsync()673 await call.RequestStream.CompleteAsync(); in RunClientCompressedStreamingAsync()
274 await call.RequestStream.CompleteAsync(); in RunStreamingPingPongAsync()302 await call.RequestStream.CompleteAsync(); in RunGenericStreamingAsync()
90 await call.RequestStream.CompleteAsync(); in AuthContextIsPopulated()
130 await call.RequestStream.CompleteAsync(); in RecordRoute()183 await call.RequestStream.CompleteAsync(); in RouteChat()
36 Task CompleteAsync(); in CompleteAsync() method
191 var completeTask = requestStream.CompleteAsync(); in ClientStreaming_MoreRequests_Success()317 requestStream.CompleteAsync(); in ClientStreaming_WriteAfterCompleteThrowsInvalidOperationException()343 Assert.DoesNotThrowAsync(async () => await requestStream.CompleteAsync()); in ClientStreaming_CompleteAfterReceivingStatusSucceeds()477 var writeTask1 = requestStream.CompleteAsync(); in DuplexStreaming_NoRequestNoResponse_Success()519 Assert.DoesNotThrowAsync(async () => await requestStream.CompleteAsync()); in DuplexStreaming_CompleteAfterReceivingStatusSuceeds()
41 public Task CompleteAsync() in CompleteAsync() method in Grpc.Core.Internal.ClientRequestStream
69 await streamWriter.CompleteAsync().ConfigureAwait(false);
135 await call.RequestStream.CompleteAsync(); in SingleRequestAsync()