diff options
author | Craig Tiller <ctiller@google.com> | 2016-07-07 21:02:08 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2016-07-07 21:02:08 -0700 |
commit | b1793a6780e48a15f72229d84b3a9c63c0b46d8e (patch) | |
tree | d7ec6a7b11ce2b4ccb3cb36908a2b18ecfdcfd74 /src/csharp/Grpc.Core/Internal/ServerResponseStream.cs | |
parent | c9d4b81dabf4dc2c262fc771c31790f2d60fe551 (diff) | |
parent | c28a6c1b3b4d68da7661997cd56d305b254a7d0b (diff) |
Merge github.com:grpc/grpc into atm2
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 |