Searched refs:streamingWriteTcs (Results 1 – 3 of 3) sorted by relevance
55 …protected TaskCompletionSource<object> streamingWriteTcs; // Completion of a pending streaming wr… field in Grpc.Core.Internal.AsyncCallBase133 streamingWriteTcs = new TaskCompletionSource<object>(); in SendMessageInternalAsync()134 return streamingWriteTcs.Task; in SendMessageInternalAsync()171 …bool noMoreSendCompletions = streamingWriteTcs == null && (halfcloseRequested || cancelRequested |… in ReleaseResourcesIfPossible()256 origTcs = streamingWriteTcs; in HandleSendFinished()257 streamingWriteTcs = null; in HandleSendFinished()
335 streamingWriteTcs = new TaskCompletionSource<object>(); in SendCloseFromClientAsync()336 return streamingWriteTcs.Task; in SendCloseFromClientAsync()451 …GrpcPreconditions.CheckState(streamingWriteTcs == null, "Only one write can be pending at a time."… in CheckSendPreconditionsClientSide()562 delayedStreamingWriteTcs = streamingWriteTcs; in HandleUnaryResponse()563 streamingWriteTcs = null; in HandleUnaryResponse()608 delayedStreamingWriteTcs = streamingWriteTcs; in HandleFinished()609 streamingWriteTcs = null; in HandleFinished()
121 streamingWriteTcs = new TaskCompletionSource<object>(); in SendInitialMetadataAsync()122 return streamingWriteTcs.Task; in SendInitialMetadataAsync()196 …GrpcPreconditions.CheckState(streamingWriteTcs == null, "Only one write can be pending at a time"); in CheckSendAllowedOrEarlyResult()