diff options
author | Jan Tattermusch <jtattermusch@google.com> | 2016-05-19 21:25:54 -0700 |
---|---|---|
committer | Jan Tattermusch <jtattermusch@google.com> | 2016-05-23 11:06:40 -0400 |
commit | 82e4581898bcee7dc83015fd5a1ae9eb25511757 (patch) | |
tree | 6ae83bdc94c9fdf93d85437b59ccb0eb01206930 /src/csharp/Grpc.Core/Internal/ServerResponseStream.cs | |
parent | afe1fe8a09712084b6cce54f88dff12d85da2b8b (diff) |
get rid of AsyncCompletionDelegate
Diffstat (limited to 'src/csharp/Grpc.Core/Internal/ServerResponseStream.cs')
-rw-r--r-- | src/csharp/Grpc.Core/Internal/ServerResponseStream.cs | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/src/csharp/Grpc.Core/Internal/ServerResponseStream.cs b/src/csharp/Grpc.Core/Internal/ServerResponseStream.cs index ecfee0bfdd..25b79b4398 100644 --- a/src/csharp/Grpc.Core/Internal/ServerResponseStream.cs +++ b/src/csharp/Grpc.Core/Internal/ServerResponseStream.cs @@ -52,16 +52,12 @@ namespace Grpc.Core.Internal public Task WriteAsync(TResponse message) { - var taskSource = new AsyncCompletionTaskSource<object>(); - call.StartSendMessage(message, GetWriteFlags(), taskSource.CompletionDelegate); - return taskSource.Task; + return call.SendMessageAsync(message, GetWriteFlags()); } public Task WriteResponseHeadersAsync(Metadata responseHeaders) { - var taskSource = new AsyncCompletionTaskSource<object>(); - call.StartSendInitialMetadata(responseHeaders, taskSource.CompletionDelegate); - return taskSource.Task; + return call.SendInitialMetadataAsync(responseHeaders); } public WriteOptions WriteOptions |