From d5dafae2cc287d41e97885322ad8e9f0dd416bb7 Mon Sep 17 00:00:00 2001 From: BrennanConroy Date: Wed, 28 Mar 2018 18:03:48 -0700 Subject: [PATCH] Always flush in WebSocketsTransport (#1756) --- .../Internal/WebSocketsTransport.cs | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) diff --git a/src/Microsoft.AspNetCore.Sockets.Client.Http/Internal/WebSocketsTransport.cs b/src/Microsoft.AspNetCore.Sockets.Client.Http/Internal/WebSocketsTransport.cs index e5e71d3b75..f833185d67 100644 --- a/src/Microsoft.AspNetCore.Sockets.Client.Http/Internal/WebSocketsTransport.cs +++ b/src/Microsoft.AspNetCore.Sockets.Client.Http/Internal/WebSocketsTransport.cs @@ -208,16 +208,13 @@ namespace Microsoft.AspNetCore.Sockets.Client.Internal _application.Output.Advance(receiveResult.Count); - if (receiveResult.EndOfMessage) - { - var flushResult = await _application.Output.FlushAsync(); + var flushResult = await _application.Output.FlushAsync(); - // We canceled in the middle of applying back pressure - // or if the consumer is done - if (flushResult.IsCanceled || flushResult.IsCompleted) - { - break; - } + // We canceled in the middle of applying back pressure + // or if the consumer is done + if (flushResult.IsCanceled || flushResult.IsCompleted) + { + break; } } }