Searched refs:streamingReadTcs (Results 1 – 2 of 2) sorted by relevance
54 …protected TaskCompletionSource<TRead> streamingReadTcs; // Completion of a pending streaming read… field in Grpc.Core.Internal.AsyncCallBase150 … GrpcPreconditions.CheckState(streamingReadTcs != null, "Call does not support streaming reads."); in ReadMessageInternalAsync()151 return streamingReadTcs.Task; in ReadMessageInternalAsync()154 … GrpcPreconditions.CheckState(streamingReadTcs == null, "Only one read can be pending at a time"); in ReadMessageInternalAsync()158 streamingReadTcs = new TaskCompletionSource<TRead>(); in ReadMessageInternalAsync()159 return streamingReadTcs.Task; in ReadMessageInternalAsync()332 origTcs = streamingReadTcs; in HandleReadFinished()349 streamingReadTcs = null; in HandleReadFinished()
213 if (streamingReadTcs == null) in HandleFinishedServerside()218 streamingReadTcs = new TaskCompletionSource<TRequest>(); in HandleFinishedServerside()219 streamingReadTcs.SetResult(default(TRequest)); in HandleFinishedServerside()