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

Fixed tests

Browse Source
This commit is contained in:
Jkorf 2021-09-14 12:19:51 +02:00
parent 31d0122096
commit f5df46a8a5
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
CryptoExchange.Net.UnitTests/SocketClientTests.cs
View File

@ -57,7 +57,7 @@ namespace CryptoExchange.Net.UnitTests
var sub = new SocketConnection(client, socket); var sub = new SocketConnection(client, socket);
var rstEvent = new ManualResetEvent(false); var rstEvent = new ManualResetEvent(false);
JToken result = null; JToken result = null;
sub.AddSubscription(SocketSubscription.CreateForIdentifier("TestHandler", true, (messageEvent) => sub.AddSubscription(SocketSubscription.CreateForIdentifier(10, "TestHandler", true, (messageEvent) =>
{ {
result = messageEvent.JsonData; result = messageEvent.JsonData;
rstEvent.Set(); rstEvent.Set();
@ -85,7 +85,7 @@ namespace CryptoExchange.Net.UnitTests
var sub = new SocketConnection(client, socket); var sub = new SocketConnection(client, socket);
var rstEvent = new ManualResetEvent(false); var rstEvent = new ManualResetEvent(false);
string original = null; string original = null;
sub.AddSubscription(SocketSubscription.CreateForIdentifier("TestHandler", true, (messageEvent) => sub.AddSubscription(SocketSubscription.CreateForIdentifier(10, "TestHandler", true, (messageEvent) =>
{ {
original = messageEvent.OriginalData; original = messageEvent.OriginalData;
rstEvent.Set(); rstEvent.Set();
@ -137,7 +137,7 @@ namespace CryptoExchange.Net.UnitTests
socket.CanConnect = true; socket.CanConnect = true;
var sub = new SocketConnection(client, socket); var sub = new SocketConnection(client, socket);
client.ConnectSocketSub(sub); client.ConnectSocketSub(sub);
var ups = new UpdateSubscription(sub, SocketSubscription.CreateForIdentifier("Test", true, (e) => {})); var ups = new UpdateSubscription(sub, SocketSubscription.CreateForIdentifier(10, "Test", true, (e) => {}));
// act // act
client.UnsubscribeAsync(ups).Wait(); client.UnsubscribeAsync(ups).Wait();