From eef2f14c78a66673b8328e463f40977831d99f16 Mon Sep 17 00:00:00 2001
From: David Fowler <davidfowl@gmail.com>
Date: Fri, 7 Oct 2016 01:06:04 -0700
Subject: [PATCH] Flush even before we get end of message

---
 src/Microsoft.AspNetCore.Sockets/WebSockets.cs | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git a/src/Microsoft.AspNetCore.Sockets/WebSockets.cs b/src/Microsoft.AspNetCore.Sockets/WebSockets.cs
index 906c36fced..64fc41d402 100644
--- a/src/Microsoft.AspNetCore.Sockets/WebSockets.cs
+++ b/src/Microsoft.AspNetCore.Sockets/WebSockets.cs
@@ -54,14 +54,11 @@ namespace Microsoft.AspNetCore.Sockets
                 {
                     outputBuffer.Advance(result.Count);
 
-                    if (result.EndOfMessage)
-                    {
-                        // Flush when we get an entire message
-                        await outputBuffer.FlushAsync();
+                    // Flush the written data to the channel
+                    await outputBuffer.FlushAsync();
 
-                        // Allocate a new buffer to further writing
-                        outputBuffer = _channel.Input.Alloc();
-                    }
+                    // Allocate a new buffer to further writing
+                    outputBuffer = _channel.Input.Alloc();
                 }
                 else
                 {