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

wip

Browse Source
This commit is contained in:
JKorf 2024-01-16 19:12:56 +01:00
parent 9ead87d350
commit b057974cd0
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CryptoExchange.Net/Objects/Sockets/StreamMessageParseCallback.cs
View File

@ -14,6 +14,6 @@ namespace CryptoExchange.Net.Objects.Sockets
{ {
public Func<WebSocketMessageType, Stream, Stream>? PreProcessCallback { get; set; } public Func<WebSocketMessageType, Stream, Stream>? PreProcessCallback { get; set; }
public Func<IMessageAccessor, string?> GetStreamIdentifier { get; set; } public Func<IMessageAccessor, string?> GetStreamIdentifier { get; set; }
public Func<IMessageAccessor, string?> GetTypeIdentifier { get; set; } public Func<IMessageAccessor, string, string?> GetTypeIdentifier { get; set; } = (accessor, streamId) => streamId;
} }
} }

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

@ -378,7 +378,7 @@ namespace CryptoExchange.Net.Sockets
if (streamIdentity == null) if (streamIdentity == null)
return null; return null;
var typeIdentity = ApiClient.Pipeline.GetTypeIdentifier(accessor); var typeIdentity = ApiClient.Pipeline.GetTypeIdentifier(accessor, streamIdentity);
var typeResult = _listenerManager.IdToType(streamIdentity, typeIdentity); var typeResult = _listenerManager.IdToType(streamIdentity, typeIdentity);
if (typeResult == null) if (typeResult == null)
return null; return null;