Consume in single call

Author: benaadams

src/Microsoft.AspNet.Server.Kestrel/Http/Frame.cs

@@ -232,10 +232,8 @@ public async Task RequestProcessingAsync()
 
                             await ProduceEnd();
 
-                            while (await MessageBody.SkipAsync() != 0)
-                            {
-                                // Finish reading the request body in case the app did not.
-                            }
+                            // Finish reading the request body in case the app did not.
+                            await MessageBody.Consume();
                         }
 
                         terminated = !_keepAlive;

src/Microsoft.AspNet.Server.Kestrel/Http/MessageBody.cs

@@ -38,20 +38,22 @@ protected MessageBody(FrameContext context)
             return result;
         }
 
-        public Task<int> SkipAsync(CancellationToken cancellationToken = default(CancellationToken))
+        public async Task Consume(CancellationToken cancellationToken = default(CancellationToken))
         {
-            Task<int> result = null;
-            var send100Continue = 0;
-            result = SkipAsyncImplementation(cancellationToken);
-            if (!result.IsCompleted)
-            {
-                send100Continue = Interlocked.Exchange(ref _send100Continue, 0);
-            }
-            if (send100Continue == 1)
+            Task<int> result;
+            do
             {
-                _context.FrameControl.ProduceContinue();
-            }
-            return result;
+                var send100Continue = 0;
+                result = SkipAsyncImplementation(cancellationToken);
+                if (!result.IsCompleted)
+                {
+                    send100Continue = Interlocked.Exchange(ref _send100Continue, 0);
+                }
+                if (send100Continue == 1)
+                {
+                    _context.FrameControl.ProduceContinue();
+                }
+            } while (await result != 0);
         }
 
         public abstract Task<int> ReadAsyncImplementation(ArraySegment<byte> buffer, CancellationToken cancellationToken);