flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2025-12-13 09:08:59 +00:00
Code Issues Releases Wiki Activity

wip

Browse Source
This commit is contained in:
JKorf 2025-11-20 21:25:56 +01:00
parent 3a7ac88c53
commit 2b1872a868
1 changed files with 2 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
CryptoExchange.Net/Sockets/CryptoExchangeWebSocketClient.cs
View File

@ -33,11 +33,6 @@ namespace CryptoExchange.Net.Sockets
}
internal static int _lastStreamId;
#if NET9_0_OR_GREATER
private static readonly Lock _streamIdLock = new Lock();
#else
private static readonly object _streamIdLock = new object();
#endif
private static readonly ArrayPool<byte> _receiveBufferPool = ArrayPool<byte>.Shared;
private readonly AsyncResetEvent _sendEvent;
@ -975,14 +970,8 @@ namespace CryptoExchange.Net.Sockets
/// Get the next identifier
/// </summary>
/// <returns></returns>
private static int NextStreamId()
{
lock (_streamIdLock)
{
_lastStreamId++;
return _lastStreamId;
}
}
private static int NextStreamId() => Interlocked.Increment(ref _lastStreamId);
/// <summary>
/// Update the received messages list, removing messages received longer than 3s ago