diff --git a/test/Kestrel.InMemory.FunctionalTests/BadHttpRequestTests.cs b/test/Kestrel.InMemory.FunctionalTests/BadHttpRequestTests.cs
index b566c5617f..962c725cef 100644
--- a/test/Kestrel.InMemory.FunctionalTests/BadHttpRequestTests.cs
+++ b/test/Kestrel.InMemory.FunctionalTests/BadHttpRequestTests.cs
@@ -183,7 +183,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "GET /\x0D\0x0ALocation:http://www.contoso.com/ HTTP/1.1",
                         "Host:\r\n\r\n");
 
-                    await client.ReceiveStartsWith("HTTP/1.1 400");
+                    await client.Receive("HTTP/1.1 400");
                 }
             }
         }
@@ -225,7 +225,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                 ""
             };
 
-            await connection.ReceiveForcedEnd(lines.Where(f => f != null).ToArray());
+            await connection.ReceiveEnd(lines.Where(f => f != null).ToArray());
         }
 
         public static TheoryData<string, string> InvalidRequestLineData
diff --git a/test/Kestrel.InMemory.FunctionalTests/ChunkedRequestTests.cs b/test/Kestrel.InMemory.FunctionalTests/ChunkedRequestTests.cs
index 28cc4dd1d9..5b176f6c57 100644
--- a/test/Kestrel.InMemory.FunctionalTests/ChunkedRequestTests.cs
+++ b/test/Kestrel.InMemory.FunctionalTests/ChunkedRequestTests.cs
@@ -66,7 +66,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "0",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -106,7 +106,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Content-Length: 11",
                         "",
                         "Hello World");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -153,7 +153,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Content-Length: 7",
                         "",
                         "Goodbye");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 11",
@@ -251,7 +251,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                 using (var connection = server.CreateConnection())
                 {
                     await connection.Send(fullRequest);
-                    await connection.ReceiveEnd(expectedFullResponse);
+                    await connection.Receive(expectedFullResponse);
                 }
             }
         }
@@ -289,7 +289,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         $"{trailingHeaderLine}",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 431 Request Header Fields Too Large",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -330,7 +330,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         $"{trailingHeaderLine}",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 431 Request Header Fields Too Large",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -422,7 +422,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                 using (var connection = server.CreateConnection())
                 {
                     await connection.Send(fullRequest);
-                    await connection.ReceiveEnd(expectedFullResponse);
+                    await connection.Receive(expectedFullResponse);
                 }
             }
         }
@@ -461,7 +461,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "HTTP/1.1 400 Bad Request",
                         "Connection: close",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 0",
                         "",
@@ -505,7 +505,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "HTTP/1.1 400 Bad Request",
                         "Connection: close",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 0",
                         "",
@@ -537,7 +537,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "",
                         "");
 
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 400 Bad Request",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -561,7 +561,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "",
                         "");
 
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 400 Bad Request",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -583,7 +583,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "",
                         "");
 
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 400 Bad Request",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -607,7 +607,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "",
                         "");
 
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 400 Bad Request",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
diff --git a/test/Kestrel.InMemory.FunctionalTests/ChunkedResponseTests.cs b/test/Kestrel.InMemory.FunctionalTests/ChunkedResponseTests.cs
index 8fcb728e32..bbbc9d5489 100644
--- a/test/Kestrel.InMemory.FunctionalTests/ChunkedResponseTests.cs
+++ b/test/Kestrel.InMemory.FunctionalTests/ChunkedResponseTests.cs
@@ -34,7 +34,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Transfer-Encoding: chunked",
@@ -170,7 +170,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host: ",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Transfer-Encoding: chunked",
@@ -220,7 +220,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
 
                     flushed.Release();
 
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "c",
                         "Hello World!",
                         "0",
@@ -248,7 +248,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host: ",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Transfer-Encoding: chunked",
@@ -281,7 +281,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host: ",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Transfer-Encoding: chunked",
@@ -315,7 +315,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "");
 
                     // Headers are sent before connection is closed, but chunked body terminator isn't sent
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Transfer-Encoding: chunked",
@@ -361,7 +361,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
 
                     flushWh.SetResult(null);
 
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "6",
                         "World!",
                         "0",
@@ -393,7 +393,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host: ",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Transfer-Encoding: chunked",
diff --git a/test/Kestrel.InMemory.FunctionalTests/DefaultHeaderTests.cs b/test/Kestrel.InMemory.FunctionalTests/DefaultHeaderTests.cs
index cd093c0880..19cd772d2b 100644
--- a/test/Kestrel.InMemory.FunctionalTests/DefaultHeaderTests.cs
+++ b/test/Kestrel.InMemory.FunctionalTests/DefaultHeaderTests.cs
@@ -31,7 +31,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "",
                         "");
 
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Server: Kestrel",
diff --git a/test/Kestrel.InMemory.FunctionalTests/MaxRequestBodySizeTests.cs b/test/Kestrel.InMemory.FunctionalTests/MaxRequestBodySizeTests.cs
index 351bf7f7ec..dc48146ca7 100644
--- a/test/Kestrel.InMemory.FunctionalTests/MaxRequestBodySizeTests.cs
+++ b/test/Kestrel.InMemory.FunctionalTests/MaxRequestBodySizeTests.cs
@@ -40,7 +40,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Content-Length: " + (globalMaxRequestBodySize + 1),
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 413 Payload Too Large",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -86,7 +86,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Content-Length: " + (perRequestMaxRequestBodySize + 1),
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 413 Payload Too Large",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -157,7 +157,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Content-Length: 1",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         $"Date: {server.Context.DateHeaderValue}",
                         "Content-Length: 0",
@@ -246,7 +246,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         $"Date: {server.Context.DateHeaderValue}",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd();
+                    await connection.ReceiveEnd();
                 }
             }
 
@@ -279,7 +279,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Content-Length: " + (new KestrelServerLimits().MaxRequestBodySize + 1),
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 413 Payload Too Large",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -326,7 +326,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Transfer-Encoding: chunked",
                         "",
                         chunkedPayload);
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 413 Payload Too Large",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -435,7 +435,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Transfer-Encoding: chunked",
                         "",
                         chunkedPayload);
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         $"Date: {server.Context.DateHeaderValue}",
                         "Content-Length: 0",
@@ -478,7 +478,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Transfer-Encoding: chunked",
                         "",
                         "1\r\n");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 413 Payload Too Large",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
diff --git a/test/Kestrel.InMemory.FunctionalTests/MaxRequestLineSizeTests.cs b/test/Kestrel.InMemory.FunctionalTests/MaxRequestLineSizeTests.cs
index 27f903e64d..67255991c0 100644
--- a/test/Kestrel.InMemory.FunctionalTests/MaxRequestLineSizeTests.cs
+++ b/test/Kestrel.InMemory.FunctionalTests/MaxRequestLineSizeTests.cs
@@ -33,7 +33,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                 using (var connection = server.CreateConnection())
                 {
                     await connection.Send(request);
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {server.Context.DateHeaderValue}",
                         "Transfer-Encoding: chunked",
@@ -59,7 +59,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                 using (var connection = server.CreateConnection())
                 {
                     await connection.SendAll(requestLine);
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 414 URI Too Long",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
diff --git a/test/Kestrel.InMemory.FunctionalTests/RequestBodyTimeoutTests.cs b/test/Kestrel.InMemory.FunctionalTests/RequestBodyTimeoutTests.cs
index b0fe3d9017..e40f387e97 100644
--- a/test/Kestrel.InMemory.FunctionalTests/RequestBodyTimeoutTests.cs
+++ b/test/Kestrel.InMemory.FunctionalTests/RequestBodyTimeoutTests.cs
@@ -6,6 +6,7 @@ using System.Threading.Tasks;
 using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Server.Kestrel.Core;
 using Microsoft.AspNetCore.Server.Kestrel.Core.Features;
+using Microsoft.AspNetCore.Server.Kestrel.Core.Internal.Http;
 using Microsoft.AspNetCore.Server.Kestrel.Core.Internal.Infrastructure;
 using Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests.TestTransport;
 using Microsoft.AspNetCore.Testing;
@@ -76,7 +77,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                     await connection.Receive(
                         "HTTP/1.1 408 Request Timeout",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "Connection: close",
                         $"Date: {serviceContext.DateHeaderValue}",
                         "Content-Length: 0",
@@ -93,6 +94,9 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
             var serviceContext = new TestServiceContext(LoggerFactory);
             serviceContext.InitializeHeartbeat();
 
+            // Ensure there's still a constant date header value.
+            serviceContext.DateHeaderValueManager = new DateHeaderValueManager();
+
             var appRunningEvent = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
 
             using (var server = new TestServer(context =>
@@ -114,13 +118,10 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
 
                     await appRunningEvent.Task.DefaultTimeout();
 
-                    await connection.Receive(
+                    // Disconnects after response completes due to the timeout
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
-                        "");
-                    await connection.ReceiveStartsWith(
-                        "Date: ");
-                    // Disconnected due to the timeout
-                    await connection.ReceiveForcedEnd(
+                        $"Date: {serviceContext.DateHeaderValue}",
                         "Content-Length: 0",
                         "",
                         "");
@@ -188,7 +189,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                     await connection.Receive(
                         "HTTP/1.1 200 OK",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         $"Date: {serviceContext.DateHeaderValue}",
                         "Content-Length: 12",
                         "",
diff --git a/test/Kestrel.InMemory.FunctionalTests/RequestHeaderLimitsTests.cs b/test/Kestrel.InMemory.FunctionalTests/RequestHeaderLimitsTests.cs
index 6976cb5953..7ce9cea8e2 100644
--- a/test/Kestrel.InMemory.FunctionalTests/RequestHeaderLimitsTests.cs
+++ b/test/Kestrel.InMemory.FunctionalTests/RequestHeaderLimitsTests.cs
@@ -32,7 +32,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                 using (var connection = server.CreateConnection())
                 {
                     await connection.Send($"GET / HTTP/1.1\r\n{headers}\r\n");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {server.Context.DateHeaderValue}",
                         "Transfer-Encoding: chunked",
@@ -64,7 +64,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                 using (var connection = server.CreateConnection())
                 {
                     await connection.Send($"GET / HTTP/1.1\r\n{headers}\r\n");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {server.Context.DateHeaderValue}",
                         "Transfer-Encoding: chunked",
@@ -90,7 +90,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                 using (var connection = server.CreateConnection())
                 {
                     await connection.SendAll($"GET / HTTP/1.1\r\n{headers}\r\n");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 431 Request Header Fields Too Large",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -114,7 +114,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                 using (var connection = server.CreateConnection())
                 {
                     await connection.SendAll($"GET / HTTP/1.1\r\n{headers}\r\n");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 431 Request Header Fields Too Large",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
diff --git a/test/Kestrel.InMemory.FunctionalTests/RequestTargetProcessingTests.cs b/test/Kestrel.InMemory.FunctionalTests/RequestTargetProcessingTests.cs
index 8cfd3edaf9..e4c9b55944 100644
--- a/test/Kestrel.InMemory.FunctionalTests/RequestTargetProcessingTests.cs
+++ b/test/Kestrel.InMemory.FunctionalTests/RequestTargetProcessingTests.cs
@@ -35,7 +35,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 11",
@@ -80,7 +80,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 11",
@@ -119,7 +119,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         $"Host: {host}",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 11",
diff --git a/test/Kestrel.InMemory.FunctionalTests/RequestTests.cs b/test/Kestrel.InMemory.FunctionalTests/RequestTests.cs
index 6760c4b0b5..0e64566c6e 100644
--- a/test/Kestrel.InMemory.FunctionalTests/RequestTests.cs
+++ b/test/Kestrel.InMemory.FunctionalTests/RequestTests.cs
@@ -342,7 +342,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "GET / HTTP/1.0",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -358,7 +358,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Content-Length: 11",
                         "",
                         "Hello World");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -391,7 +391,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 0",
                         "\r\n");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -431,7 +431,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "",
                         "Goodbye");
 
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -486,7 +486,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "",
                         "Goodbye");
 
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -518,7 +518,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "",
                         "");
                     await connection.Send("Hello World");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -551,7 +551,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Connection: close",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -567,7 +567,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -592,7 +592,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                     await connection.Send(
                         "POST / HTTP/1.1");
                     connection.ShutdownSend();
-                    await connection.ReceiveForcedEnd();
+                    await connection.ReceiveEnd();
                 }
 
                 using (var connection = server.CreateConnection())
@@ -602,7 +602,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "Content-Length: 7");
                     connection.ShutdownSend();
-                    await connection.ReceiveForcedEnd();
+                    await connection.ReceiveEnd();
                 }
             }
         }
@@ -643,7 +643,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 0",
@@ -687,7 +687,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Connection: Upgrade",
                         "",
                         message);
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 101 Switching Protocols",
                         "Connection: Upgrade",
                         $"Date: {testContext.DateHeaderValue}",
@@ -895,7 +895,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "",
                         "hello");
 
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -928,7 +928,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "",
                         "hello");
 
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 101 Switching Protocols",
                         "Connection: Upgrade",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -988,13 +988,10 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
 
                     await connection.Send("b");
 
-                    await connection.Receive(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 101 Switching Protocols",
                         "Connection: Upgrade",
-                        "");
-                    await connection.ReceiveStartsWith(
-                        $"Date: ");
-                    await connection.ReceiveForcedEnd(
+                        $"Date: {server.Context.DateHeaderValue}",
                         "",
                         "hello");
                 }
diff --git a/test/Kestrel.InMemory.FunctionalTests/ResponseTests.cs b/test/Kestrel.InMemory.FunctionalTests/ResponseTests.cs
index 26c1433b16..12bddb8d31 100644
--- a/test/Kestrel.InMemory.FunctionalTests/ResponseTests.cs
+++ b/test/Kestrel.InMemory.FunctionalTests/ResponseTests.cs
@@ -340,7 +340,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "",
                         "gg");
 
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         $"Date: {server.Context.DateHeaderValue}",
                         "Content-Length: 0",
@@ -372,7 +372,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Transfer-Encoding: chunked",
                         "",
                         "gg");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         $"Date: {server.Context.DateHeaderValue}",
                         "Content-Length: 0",
@@ -573,7 +573,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         $"HTTP/1.1 200 OK",
                         $"Date: {server.Context.DateHeaderValue}",
                         "Content-Length: 11",
@@ -611,7 +611,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         $"HTTP/1.1 500 Internal Server Error",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -646,7 +646,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         $"HTTP/1.1 500 Internal Server Error",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -1029,7 +1029,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
 
                     flushed.SetResult(null);
 
-                    await connection.ReceiveEnd("hello, world");
+                    await connection.Receive("hello, world");
                 }
             }
         }
@@ -1093,7 +1093,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -1109,7 +1109,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Connection: keep-alive",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -1139,7 +1139,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: keep-alive",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -1155,7 +1155,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Connection: keep-alive",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: keep-alive",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -1199,7 +1199,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {server.Context.DateHeaderValue}",
                         $"Transfer-Encoding: {responseTransferEncoding}",
@@ -1436,7 +1436,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                     // This will receive a success response because the server flushed the response
                     // before reading the malformed chunk header in the request, but then it will close
                     // the connection.
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         $"Date: {server.Context.DateHeaderValue}",
                         "Content-Length: 0",
@@ -1548,7 +1548,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                     // If 100 Continue sets HttpProtocol.HasResponseStarted to true,
                     // a success response will be produced before the server sees the
                     // bad chunk header above, making this test fail.
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 400 Bad Request",
                         "Connection: close",
                         $"Date: {server.Context.DateHeaderValue}",
@@ -1650,7 +1650,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Connection: keep-alive",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 0",
@@ -1723,7 +1723,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "",
@@ -1769,7 +1769,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Content-Length: 3",
                         "",
                         "200");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 204 No Content",
                         $"Date: {testContext.DateHeaderValue}",
                         "",
@@ -1809,7 +1809,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Connection: Upgrade",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 101 Switching Protocols",
                         "Connection: Upgrade",
                         $"Date: {testContext.DateHeaderValue}",
@@ -1824,7 +1824,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Connection: keep-alive, Upgrade",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 101 Switching Protocols",
                         "Connection: Upgrade",
                         $"Date: {testContext.DateHeaderValue}",
@@ -1866,7 +1866,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Connection: close",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 500 Internal Server Error",
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 0",
@@ -1923,7 +1923,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 500 Internal Server Error",
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 0",
@@ -1977,7 +1977,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 11",
@@ -2020,7 +2020,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 11",
@@ -2061,7 +2061,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 11",
@@ -2093,7 +2093,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "GET / HTTP/1.0",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd(
+                    await connection.ReceiveEnd(
                         "HTTP/1.1 200 OK",
                         "Connection: close",
                         $"Date: {testContext.DateHeaderValue}",
@@ -2124,7 +2124,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Content-Length: 1",
                         "",
                         "");
-                    await connection.ReceiveForcedEnd();
+                    await connection.ReceiveEnd();
                 }
             }
         }
@@ -2165,7 +2165,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         "Content-Length: 0",
@@ -2214,7 +2214,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         $"Content-Length: {response.Length}",
@@ -2265,7 +2265,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         "Host:",
                         "",
                         "");
-                    await connection.ReceiveEnd(
+                    await connection.Receive(
                         "HTTP/1.1 200 OK",
                         $"Date: {testContext.DateHeaderValue}",
                         $"Content-Length: {response.Length}",
@@ -2461,7 +2461,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
 
                         if (expectedClientStatusCode == HttpStatusCode.OK)
                         {
-                            await connection.ReceiveForcedEnd(
+                            await connection.ReceiveEnd(
                                 "HTTP/1.1 200 OK",
                                 $"Date: {server.Context.DateHeaderValue}",
                                 "Content-Length: 0",
@@ -2470,7 +2470,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                         }
                         else
                         {
-                            await connection.ReceiveForcedEnd(
+                            await connection.ReceiveEnd(
                                 "HTTP/1.1 400 Bad Request",
                                 "Connection: close",
                                 $"Date: {server.Context.DateHeaderValue}",
diff --git a/test/Kestrel.InMemory.FunctionalTests/UpgradeTests.cs b/test/Kestrel.InMemory.FunctionalTests/UpgradeTests.cs
index 7dd73fe650..78ee00fb4e 100644
--- a/test/Kestrel.InMemory.FunctionalTests/UpgradeTests.cs
+++ b/test/Kestrel.InMemory.FunctionalTests/UpgradeTests.cs
@@ -159,7 +159,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                     "",
                     "");
 
-                await connection.ReceiveForcedEnd(
+                await connection.ReceiveEnd(
                     "HTTP/1.1 400 Bad Request",
                     "Connection: close",
                     $"Date: {server.Context.DateHeaderValue}",
@@ -205,7 +205,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.InMemory.FunctionalTests
                     "Connection: Upgrade",
                     "",
                     "");
-                await connection.ReceiveForcedEnd(
+                await connection.ReceiveEnd(
                     "HTTP/1.1 400 Bad Request",
                     "Connection: close",
                     $"Date: {server.Context.DateHeaderValue}",
diff --git a/test/Kestrel.Transport.FunctionalTests/RequestTests.cs b/test/Kestrel.Transport.FunctionalTests/RequestTests.cs
index ce253762df..1128dfae17 100644
--- a/test/Kestrel.Transport.FunctionalTests/RequestTests.cs
+++ b/test/Kestrel.Transport.FunctionalTests/RequestTests.cs
@@ -173,6 +173,52 @@ namespace Microsoft.AspNetCore.Server.Kestrel.FunctionalTests
             }
         }
 
+        [Fact]
+        public async Task CanHandleMultipleConcurrentRequests()
+        {
+            var requestNumber = 0;
+            var ensureConcurrentReqeustTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
+
+            using (var server = new TestServer(async context =>
+            {
+                if (Interlocked.Increment(ref requestNumber) == 1)
+                {
+                    await ensureConcurrentReqeustTcs.Task.DefaultTimeout();
+                }
+                else
+                {
+                    ensureConcurrentReqeustTcs.SetResult(null);
+                }
+            }, new TestServiceContext(LoggerFactory)))
+            {
+                using (var connection1 = server.CreateConnection())
+                using (var connection2 = server.CreateConnection())
+                {
+                    await connection1.Send(
+                        "GET / HTTP/1.1",
+                        "Host:",
+                        "",
+                        "");
+                    await connection2.Send(
+                        "GET / HTTP/1.1",
+                        "Host:",
+                        "",
+                        "");
+
+                    await connection1.Receive($"HTTP/1.1 200 OK",
+                        $"Date: {server.Context.DateHeaderValue}",
+                        "Content-Length: 0",
+                        "",
+                        "");
+                    await connection2.Receive($"HTTP/1.1 200 OK",
+                        $"Date: {server.Context.DateHeaderValue}",
+                        "Content-Length: 0",
+                        "",
+                        "");
+                }
+            }
+        }
+
         [Fact]
         public async Task ConnectionResetPriorToRequestIsLoggedAsDebug()
         {
@@ -575,7 +621,17 @@ namespace Microsoft.AspNetCore.Server.Kestrel.FunctionalTests
                         "");
 
                     await connectionClosedTcs.Task.DefaultTimeout();
-                    await connection.ReceiveForcedEnd();
+
+                    try
+                    {
+                        await connection.ReceiveEnd();
+                    }
+                    catch (IOException)
+                    {
+                        // The server is forcefully closing the connection so an IOException:
+                        // "Unable to read data from the transport connection: An existing connection was forcibly closed by the remote host."
+                        // isn't guaranteed but not unexpected.
+                    }
                 }
             }
         }
diff --git a/test/shared/StreamBackedTestConnection.cs b/test/shared/StreamBackedTestConnection.cs
index 59cae5dd6c..82ac8a0f5d 100644
--- a/test/shared/StreamBackedTestConnection.cs
+++ b/test/shared/StreamBackedTestConnection.cs
@@ -130,64 +130,12 @@ namespace Microsoft.AspNetCore.Testing
         public async Task ReceiveEnd(params string[] lines)
         {
             await Receive(lines).ConfigureAwait(false);
-            ShutdownSend();
             var ch = new char[128];
             var count = await _reader.ReadAsync(ch, 0, 128).TimeoutAfter(Timeout).ConfigureAwait(false);
             var text = new string(ch, 0, count);
             Assert.Equal("", text);
         }
 
-        public async Task ReceiveForcedEnd(params string[] lines)
-        {
-            await Receive(lines).ConfigureAwait(false);
-
-            try
-            {
-                var ch = new char[128];
-                var count = await _reader.ReadAsync(ch, 0, 128).TimeoutAfter(Timeout).ConfigureAwait(false);
-                var text = new string(ch, 0, count);
-                Assert.Equal("", text);
-            }
-            catch (IOException)
-            {
-                // The server is forcefully closing the connection so an IOException:
-                // "Unable to read data from the transport connection: An existing connection was forcibly closed by the remote host."
-                // isn't guaranteed but not unexpected.
-            }
-        }
-
-        public async Task ReceiveStartsWith(string prefix, int maxLineLength = 1024)
-        {
-            var actual = new char[maxLineLength];
-            var offset = 0;
-
-            while (offset < maxLineLength)
-            {
-                // Read one char at a time so we don't read past the end of the line.
-                var task = _reader.ReadAsync(actual, offset, 1);
-                if (!Debugger.IsAttached)
-                {
-                    task = task.TimeoutAfter(Timeout);
-                }
-                var count = await task.ConfigureAwait(false);
-                if (count == 0)
-                {
-                    break;
-                }
-
-                Assert.True(count == 1);
-                offset++;
-
-                if (actual[offset - 1] == '\n')
-                {
-                    break;
-                }
-            }
-
-            var actualLine = new string(actual, 0, offset);
-            Assert.StartsWith(prefix, actualLine);
-        }
-
         public async Task WaitForConnectionClose()
         {
             var buffer = new byte[128];