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

Test fixes

Browse Source
This commit is contained in:
JKorf 2024-07-10 10:18:58 +02:00
parent 0d5bdf5095
commit 28da93af9d
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
CryptoExchange.Net.UnitTests/TestImplementations/TestSocket.cs
View File

@ -21,7 +21,7 @@ namespace CryptoExchange.Net.UnitTests.TestImplementations
public event Func<int, Task> OnRequestRateLimited; public event Func<int, Task> OnRequestRateLimited;
#pragma warning restore 0067 #pragma warning restore 0067
public event Func<int, Task> OnRequestSent; public event Func<int, Task> OnRequestSent;
public event Action<WebSocketMessageType, ReadOnlyMemory<byte>> OnStreamMessage; public event Func<WebSocketMessageType, ReadOnlyMemory<byte>, Task> OnStreamMessage;
public event Func<Exception, Task> OnError; public event Func<Exception, Task> OnError;
public event Func<Task> OnOpen; public event Func<Task> OnOpen;
public Func<Task<Uri>> GetReconnectionUrl { get; set; } public Func<Task<Uri>> GetReconnectionUrl { get; set; }
@ -114,7 +114,7 @@ namespace CryptoExchange.Net.UnitTests.TestImplementations
public void InvokeMessage(string data) public void InvokeMessage(string data)
{ {
OnStreamMessage?.Invoke(WebSocketMessageType.Text, new ReadOnlyMemory<byte>(Encoding.UTF8.GetBytes(data))); OnStreamMessage?.Invoke(WebSocketMessageType.Text, new ReadOnlyMemory<byte>(Encoding.UTF8.GetBytes(data))).Wait();
} }
public void SetProxy(ApiProxy proxy) public void SetProxy(ApiProxy proxy)

4
CryptoExchange.Net/Testing/Implementations/TestSocket.cs
View File

@ -72,12 +72,12 @@ namespace CryptoExchange.Net.Testing.Implementations
public void InvokeMessage(string data) public void InvokeMessage(string data)
{ {
OnStreamMessage?.Invoke(WebSocketMessageType.Text, new ReadOnlyMemory<byte>(Encoding.UTF8.GetBytes(data))); OnStreamMessage?.Invoke(WebSocketMessageType.Text, new ReadOnlyMemory<byte>(Encoding.UTF8.GetBytes(data))).Wait();
} }
public void InvokeMessage<T>(T data) public void InvokeMessage<T>(T data)
{ {
OnStreamMessage?.Invoke(WebSocketMessageType.Text, new ReadOnlyMemory<byte>(Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(data)))); OnStreamMessage?.Invoke(WebSocketMessageType.Text, new ReadOnlyMemory<byte>(Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(data)))).Wait();
} }
public Task ReconnectAsync() => throw new NotImplementedException(); public Task ReconnectAsync() => throw new NotImplementedException();