flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2025-06-07 16:06:15 +00:00
Code Issues Releases Wiki Activity

Added DoHandleReset method for websocket subscriptions

Browse Source
This commit is contained in:
Jkorf 2024-10-22 09:47:14 +02:00
parent 130ed40580
commit 3cb91296ca
2 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
CryptoExchange.Net/Sockets/SocketConnection.cs
View File

@ -268,7 +268,7 @@ namespace CryptoExchange.Net.Sockets
lock (_listenersLock) lock (_listenersLock)
{ {
foreach (var subscription in _listeners.OfType<Subscription>().Where(l => l.UserSubscription)) foreach (var subscription in _listeners.OfType<Subscription>().Where(l => l.UserSubscription))
subscription.Confirmed = false; subscription.Reset();
foreach (var query in _listeners.OfType<Query>().ToList()) foreach (var query in _listeners.OfType<Query>().ToList())
{ {
@ -293,7 +293,7 @@ namespace CryptoExchange.Net.Sockets
lock (_listenersLock) lock (_listenersLock)
{ {
foreach (var subscription in _listeners.OfType<Subscription>().Where(l => l.UserSubscription)) foreach (var subscription in _listeners.OfType<Subscription>().Where(l => l.UserSubscription))
subscription.Confirmed = false; subscription.Reset();
foreach (var query in _listeners.OfType<Query>().ToList()) foreach (var query in _listeners.OfType<Query>().ToList())
{ {

14
CryptoExchange.Net/Sockets/Subscription.cs
View File

@ -130,6 +130,20 @@ namespace CryptoExchange.Net.Sockets
return Task.FromResult(DoHandleMessage(connection, message)); return Task.FromResult(DoHandleMessage(connection, message));
} }
/// <summary>
/// Reset the subscription
/// </summary>
public void Reset()
{
Confirmed = false;
DoHandleReset();
}
/// <summary>
/// Connection has been reset, do any logic for resetting the subscription
/// </summary>
public virtual void DoHandleReset() { }
/// <summary> /// <summary>
/// Handle the update message /// Handle the update message
/// </summary> /// </summary>