Fix semaphore extra release. (#186)

EricSites · web-flow · commit 5d00667a7d03 · 2025-03-28T10:26:07.000+01:00
diff --git a/SurrealDb.Net/Internals/SurrealDbEngine.Ws.cs b/SurrealDb.Net/Internals/SurrealDbEngine.Ws.cs
@@ -1,4 +1,4 @@
-using System.Collections.Concurrent;
+﻿using System.Collections.Concurrent;
 using System.Diagnostics;
 using System.Net.WebSockets;
 using System.Reactive.Concurrency;
@@ -1347,10 +1347,10 @@ CancellationToken cancellationToken
     {
         if (!_wsClient.IsStarted || (requireInitialized && !_isInitialized))
         {
+            await _semaphoreConnect.WaitAsync(cancellationToken).ConfigureAwait(false);
+
             try
             {
-                await _semaphoreConnect.WaitAsync(cancellationToken).ConfigureAwait(false);
-
                 if (!_wsClient.IsStarted)
                 {
                     await Connect(cancellationToken).ConfigureAwait(false);

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-using System.Collections.Concurrent;`
	`1`	`+using System.Collections.Concurrent;`
`2`	`2`	`using System.Diagnostics;`
`3`	`3`	`using System.Net.WebSockets;`
`4`	`4`	`using System.Reactive.Concurrency;`
`@@ -1347,10 +1347,10 @@ CancellationToken cancellationToken`
`1347`	`1347`	`{`
`1348`	`1348`	`if (!_wsClient.IsStarted \|\| (requireInitialized && !_isInitialized))`
`1349`	`1349`	`{`
	`1350`	`+ await _semaphoreConnect.WaitAsync(cancellationToken).ConfigureAwait(false);`
	`1351`	`+`
`1350`	`1352`	`try`
`1351`	`1353`	`{`
`1352`		`- await _semaphoreConnect.WaitAsync(cancellationToken).ConfigureAwait(false);`
`1353`		`-`
`1354`	`1354`	`if (!_wsClient.IsStarted)`
`1355`	`1355`	`{`
`1356`	`1356`	`await Connect(cancellationToken).ConfigureAwait(false);`