aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/csharp/Grpc.Core/Internal/ServerResponseStream.cs
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2016-07-07 21:02:08 -0700
committerGravatar Craig Tiller <ctiller@google.com>2016-07-07 21:02:08 -0700
commitb1793a6780e48a15f72229d84b3a9c63c0b46d8e (patch)
treed7ec6a7b11ce2b4ccb3cb36908a2b18ecfdcfd74 /src/csharp/Grpc.Core/Internal/ServerResponseStream.cs
parentc9d4b81dabf4dc2c262fc771c31790f2d60fe551 (diff)
parentc28a6c1b3b4d68da7661997cd56d305b254a7d0b (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.cs8
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