diff options
author | 2016-05-18 11:00:31 -0700 | |
---|---|---|
committer | 2016-05-18 11:00:31 -0700 | |
commit | d013e9b98538710680ced4c3241ab60df9a66190 (patch) | |
tree | 637bae50948c98235f08db0a89cb2ac6008ea1ac /src/csharp/Grpc.Core/Internal/ServerRequestStream.cs | |
parent | 604490973b219aa69ee67c252173fa60cadb24b1 (diff) | |
parent | fcbe7daf832dcb616fc93ca59c3b1aab279f510e (diff) |
Merge branch 'master' of github.com:grpc/grpc into lb_pollset_propagation
Diffstat (limited to 'src/csharp/Grpc.Core/Internal/ServerRequestStream.cs')
-rw-r--r-- | src/csharp/Grpc.Core/Internal/ServerRequestStream.cs | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/src/csharp/Grpc.Core/Internal/ServerRequestStream.cs b/src/csharp/Grpc.Core/Internal/ServerRequestStream.cs index e7be82c318..d76030d1ad 100644 --- a/src/csharp/Grpc.Core/Internal/ServerRequestStream.cs +++ b/src/csharp/Grpc.Core/Internal/ServerRequestStream.cs @@ -68,9 +68,7 @@ namespace Grpc.Core.Internal { throw new InvalidOperationException("Cancellation of individual reads is not supported."); } - var taskSource = new AsyncCompletionTaskSource<TRequest>(); - call.StartReadMessage(taskSource.CompletionDelegate); - var result = await taskSource.Task.ConfigureAwait(false); + var result = await call.ReadMessageAsync().ConfigureAwait(false); this.current = result; return result != null; } |