diff options
author | Jan Tattermusch <jtattermusch@google.com> | 2016-05-02 17:17:18 -0700 |
---|---|---|
committer | Jan Tattermusch <jtattermusch@google.com> | 2016-05-03 07:59:59 -0700 |
commit | 96f21a27cb7975d52aa92197536eef0ad8dca455 (patch) | |
tree | 9ab394f79d21761528842ffae7e62f32ddea5e08 /src/csharp/Grpc.Core/Internal/AsyncCall.cs | |
parent | a83ad2aa65a04d16b484e7c4373b7db5575221a4 (diff) |
make end-of-stream idempotent
Diffstat (limited to 'src/csharp/Grpc.Core/Internal/AsyncCall.cs')
-rw-r--r-- | src/csharp/Grpc.Core/Internal/AsyncCall.cs | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/csharp/Grpc.Core/Internal/AsyncCall.cs b/src/csharp/Grpc.Core/Internal/AsyncCall.cs index 50ba617cdb..f522174bd0 100644 --- a/src/csharp/Grpc.Core/Internal/AsyncCall.cs +++ b/src/csharp/Grpc.Core/Internal/AsyncCall.cs @@ -241,11 +241,10 @@ namespace Grpc.Core.Internal /// <summary> /// Receives a streaming response. Only one pending read action is allowed at any given time. - /// completionDelegate is called when the operation finishes. /// </summary> - public void StartReadMessage(AsyncCompletionDelegate<TResponse> completionDelegate) + public Task<TResponse> ReadMessageAsync() { - StartReadMessageInternal(completionDelegate); + return ReadMessageInternalAsync(); } /// <summary> |