try catch in CloseAsync when cancellation requested

kgrudzien · kgrudzien · commit 0ae73488e81e · 2024-03-29T08:23:13.000+01:00
diff --git a/data-api/csharp-ws/CoinAPI.WebSocket.V1/CoinApiWsClient.cs b/data-api/csharp-ws/CoinAPI.WebSocket.V1/CoinApiWsClient.cs
@@ -340,10 +340,19 @@ private async Task HandleConnection(CancellationTokenSource connectionCts)
                 }
                 catch (TaskCanceledException)
                 {
-                    if (_client.State == WebSocketState.Open)
+                    try
+                    {
+                        if (_client.State == WebSocketState.Open)
+                        {
+                            await _client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Normal", CancellationToken.None);
+
+                        }
+
+                    }
+                    catch (Exception ex)
                     {
-                        await _client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Normal", CancellationToken.None);
 
+                        OnError(ex);
                     }
                 }
                 catch (Exception ex)

Original file line number	Diff line number	Diff line change
`@@ -340,10 +340,19 @@ private async Task HandleConnection(CancellationTokenSource connectionCts)`
`340`	`340`	`}`
`341`	`341`	`catch (TaskCanceledException)`
`342`	`342`	`{`
`343`		`- if (_client.State == WebSocketState.Open)`
	`343`	`+ try`
	`344`	`+ {`
	`345`	`+ if (_client.State == WebSocketState.Open)`
	`346`	`+ {`
	`347`	`+ await _client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Normal", CancellationToken.None);`
	`348`	`+`
	`349`	`+ }`
	`350`	`+`
	`351`	`+ }`
	`352`	`+ catch (Exception ex)`
`344`	`353`	`{`
`345`		`- await _client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Normal", CancellationToken.None);`
`346`	`354`
	`355`	`+ OnError(ex);`
`347`	`356`	`}`
`348`	`357`	`}`
`349`	`358`	`catch (Exception ex)`