From bb9b0cbfa52ad725b2af6f6f85f55e051cfd145c Mon Sep 17 00:00:00 2001
From: David Fowler <davidfowl@gmail.com>
Date: Sat, 1 Jun 2019 11:10:09 -0700
Subject: [PATCH] Clean up some pipes things (#10728)

- Use the Kestrel memory pool
- Fix bad casts
---
 .../src/Internal/Http/HttpProtocol.FeatureCollection.cs   | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/Servers/Kestrel/Core/src/Internal/Http/HttpProtocol.FeatureCollection.cs b/src/Servers/Kestrel/Core/src/Internal/Http/HttpProtocol.FeatureCollection.cs
index be9a2c5c0f..82b1ebfe6b 100644
--- a/src/Servers/Kestrel/Core/src/Internal/Http/HttpProtocol.FeatureCollection.cs
+++ b/src/Servers/Kestrel/Core/src/Internal/Http/HttpProtocol.FeatureCollection.cs
@@ -109,11 +109,11 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Core.Internal.Http
                 if (!ReferenceEquals(_requestStreamInternal, RequestBody))
                 {
                     _requestStreamInternal = RequestBody;
-                    RequestBodyPipeReader = PipeReader.Create(RequestBody);
+                    RequestBodyPipeReader = PipeReader.Create(RequestBody, new StreamPipeReaderOptions(_context.MemoryPool, _context.MemoryPool.GetMinimumSegmentSize(), _context.MemoryPool.GetMinimumAllocSize()));
 
                     OnCompleted((self) =>
                     {
-                        ((PipeWriter)self).Complete();
+                        ((PipeReader)self).Complete();
                         return Task.CompletedTask;
                     }, RequestBodyPipeReader);
                 }
@@ -243,11 +243,11 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Core.Internal.Http
                 if (!ReferenceEquals(_responseStreamInternal, ResponseBody))
                 {
                     _responseStreamInternal = ResponseBody;
-                    ResponseBodyPipeWriter = PipeWriter.Create(ResponseBody);
+                    ResponseBodyPipeWriter = PipeWriter.Create(ResponseBody, new StreamPipeWriterOptions(_context.MemoryPool));
 
                     OnCompleted((self) =>
                     {
-                        ((PipeReader)self).Complete();
+                        ((PipeWriter)self).Complete();
                         return Task.CompletedTask;
                     }, ResponseBodyPipeWriter);
                 }