commit 4ec975df616feb5481f5c8184854413ef8bd229f
author Jan Tattermusch <jtattermusch@google.com> Thu Jun 11 17:24:15 2015 -0700
committer Jan Tattermusch <jtattermusch@google.com> Thu Jun 11 17:24:15 2015 -0700
tree 64ec446eae860f9312a928f898e77e4577bd5d59
parent 0680527a78f5eb86e04a2e909662500172bf92a0

unknown method handler no longer needs to complete request stream

src/csharp/Grpc.Core/Internal/AsyncCallServer.cs

diff --git a/src/csharp/Grpc.Core/Internal/AsyncCallServer.cs b/src/csharp/Grpc.Core/Internal/AsyncCallServer.cs
index db1b869..4f510ba 100644
--- a/src/csharp/Grpc.Core/Internal/AsyncCallServer.cs
+++ b/src/csharp/Grpc.Core/Internal/AsyncCallServer.cs
@@ -107,6 +107,7 @@
 
                 call.StartSendStatusFromServer(status, HandleHalfclosed);
                 halfcloseRequested = true;
+                readingDone = true;
                 sendCompletionDelegate = completionDelegate;
             }
         }

src/csharp/Grpc.Core/Internal/ServerCallHandler.cs

diff --git a/src/csharp/Grpc.Core/Internal/ServerCallHandler.cs b/src/csharp/Grpc.Core/Internal/ServerCallHandler.cs
index f494d9e..c0e5bae 100644
--- a/src/csharp/Grpc.Core/Internal/ServerCallHandler.cs
+++ b/src/csharp/Grpc.Core/Internal/ServerCallHandler.cs
@@ -267,8 +267,6 @@
             var responseStream = new ServerResponseStream<byte[], byte[]>(asyncCall);
 
             await responseStream.WriteStatusAsync(new Status(StatusCode.Unimplemented, "No such method."));
-            // TODO(jtattermusch): if we don't read what client has sent, the server call never gets disposed.
-            await requestStream.ToList();
             await finishedTask;
         }
     }