Patch memory leak with subscriptions when client abruptly terminates (#668)

Author: Shane32

src/Transports.Subscriptions.WebSockets/WebSocketReaderPipeline.cs

@@ -42,26 +42,28 @@ public void LinkTo(ITargetBlock<OperationMessage> target)
 
         public async Task Complete(WebSocketCloseStatus closeStatus, string statusDescription)
         {
-            if (_socket.State != WebSocketState.Closed &&
-                _socket.State != WebSocketState.CloseSent &&
-                _socket.State != WebSocketState.Aborted)
-                try
+            try
+            {
+                if (_socket.State != WebSocketState.Closed &&
+                    _socket.State != WebSocketState.CloseSent &&
+                    _socket.State != WebSocketState.Aborted)
                 {
                     if (closeStatus == WebSocketCloseStatus.NormalClosure)
                         await _socket.CloseAsync(
-                          closeStatus,
-                          statusDescription,
-                          CancellationToken.None);
+                            closeStatus,
+                            statusDescription,
+                            CancellationToken.None);
                     else
                         await _socket.CloseOutputAsync(
-                          closeStatus,
-                          statusDescription,
-                          CancellationToken.None);
-                }
-                finally
-                {
-                    _startBlock.Complete();
+                            closeStatus,
+                            statusDescription,
+                            CancellationToken.None);
                 }
+            }
+            finally
+            {
+                _startBlock.Complete();
+            }
         }
 
         public Task Completion => _endBlock.Completion;