diff --git a/src/Servers/Kestrel/samples/PlaintextApp/Startup.cs b/src/Servers/Kestrel/samples/PlaintextApp/Startup.cs
index 28da0a6f2c67..ef1212427608 100644
--- a/src/Servers/Kestrel/samples/PlaintextApp/Startup.cs
+++ b/src/Servers/Kestrel/samples/PlaintextApp/Startup.cs
@@ -2,7 +2,9 @@
 // Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
 
 using System.IO;
+using System.IO.Pipelines;
 using System.Net;
+using System.Runtime.CompilerServices;
 using System.Text;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Builder;
@@ -18,13 +20,14 @@ public void Configure(IApplicationBuilder app)
         {
             app.Run((httpContext) =>
             {
+                var payload = _helloWorldBytes;
                 var response = httpContext.Response;
+
                 response.StatusCode = 200;
                 response.ContentType = "text/plain";
+                response.ContentLength = payload.Length;
 
-                var helloWorld = _helloWorldBytes;
-                response.ContentLength = helloWorld.Length;
-                return response.Body.WriteAsync(helloWorld, 0, helloWorld.Length);
+                return response.BodyPipe.WriteAsync(payload).GetAsTask();
             });
         }
 
@@ -42,4 +45,22 @@ public static Task Main(string[] args)
             return host.RunAsync();
         }
     }
+
+    internal static class ValueTaskExtensions
+    {
+        [MethodImpl(MethodImplOptions.AggressiveInlining)]
+        public static Task GetAsTask(this in ValueTask<FlushResult> valueTask)
+        {
+            if (valueTask.IsCompletedSuccessfully)
+            {
+                // Signal consumption to the IValueTaskSource
+                valueTask.GetAwaiter().GetResult();
+                return Task.CompletedTask;
+            }
+            else
+            {
+                return valueTask.AsTask();
+            }
+        }
+    }
 }