flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net.git synced 2026-08-11 16:32:57 +00:00
Code Issues Releases Wiki Activity

Fixed timing issue in SymbolOrderBook stopping

Browse Source
This commit is contained in:
Jkorf
2026-05-26 09:27:04 +02:00
parent 6b575be1ac
commit f176fb5db5
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
CryptoExchange.Net/OrderBook/SymbolOrderBook.cs
+6 -4
View File
@@ -333,17 +333,19 @@ namespace CryptoExchange.Net.OrderBook
{ {
_logger.OrderBookStopping(Api, Symbol); _logger.OrderBookStopping(Api, Symbol);
_cts?.Cancel(); _cts?.Cancel();
_queueEvent.Set();
if (_processTask != null)
await _processTask.ConfigureAwait(false);
if (_subscription != null) { if (_subscription != null)
{
await _subscription.CloseAsync().ConfigureAwait(false); await _subscription.CloseAsync().ConfigureAwait(false);
_subscription.ConnectionLost -= HandleConnectionLost; _subscription.ConnectionLost -= HandleConnectionLost;
_subscription.ConnectionClosed -= HandleConnectionClosed; _subscription.ConnectionClosed -= HandleConnectionClosed;
_subscription.ConnectionRestored -= HandleConnectionRestored; _subscription.ConnectionRestored -= HandleConnectionRestored;
} }
_queueEvent.Set();
if (_processTask != null)
await _processTask.ConfigureAwait(false);
Status = OrderBookStatus.Disconnected; Status = OrderBookStatus.Disconnected;
_logger.OrderBookStopped(Api, Symbol); _logger.OrderBookStopped(Api, Symbol);
} }