flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2025-06-11 01:46:12 +00:00
Code Issues Releases Wiki Activity

Added configureawaits

Browse Source
This commit is contained in:
JKorf 2018-12-06 09:50:41 +01:00
parent e41657d2e4
commit e5f712633e
2 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
CryptoExchange.Net/RestClient.cs
View File

@ -13,7 +13,6 @@ using CryptoExchange.Net.Authentication;
using CryptoExchange.Net.Interfaces; using CryptoExchange.Net.Interfaces;
using CryptoExchange.Net.Logging; using CryptoExchange.Net.Logging;
using CryptoExchange.Net.Objects; using CryptoExchange.Net.Objects;
using CryptoExchange.Net.RateLimiter;
using CryptoExchange.Net.Requests; using CryptoExchange.Net.Requests;
using Newtonsoft.Json; using Newtonsoft.Json;
using Newtonsoft.Json.Linq; using Newtonsoft.Json.Linq;
@ -90,7 +89,7 @@ namespace CryptoExchange.Net
PingReply reply; PingReply reply;
try try
{ {
reply = await ping.SendPingAsync(uri.Host); reply = await ping.SendPingAsync(uri.Host).ConfigureAwait(false);
} }
catch(PingException e) catch(PingException e)
{ {

8
CryptoExchange.Net/SocketClient.cs
View File

@ -30,7 +30,7 @@ namespace CryptoExchange.Net
protected const string DataHandlerName = "DataHandler"; protected const string DataHandlerName = "DataHandler";
protected const string AuthenticationHandlerName = "AuthenticationHandler"; protected const string AuthenticationHandlerName = "AuthenticationHandler";
protected const string SubscriptionHandlerName = "SubscriptionHandler"; protected const string SubscriptionHandlerName = "SubscriptionHandler";
protected const string PingHandlerName = "SubscriptionHandler"; protected const string PingHandlerName = "PingHandler";
protected const string DataEvent = "Data"; protected const string DataEvent = "Data";
protected const string SubscriptionEvent = "Subscription"; protected const string SubscriptionEvent = "Subscription";
@ -121,7 +121,7 @@ namespace CryptoExchange.Net
{ {
socketSubscription.Socket.OnMessage += data => ProcessMessage(socketSubscription, data); socketSubscription.Socket.OnMessage += data => ProcessMessage(socketSubscription, data);
if (await socketSubscription.Socket.Connect()) if (await socketSubscription.Socket.Connect().ConfigureAwait(false))
{ {
lock (sockets) lock (sockets)
sockets.Add(socketSubscription); sockets.Add(socketSubscription);
@ -239,7 +239,7 @@ namespace CryptoExchange.Net
public virtual async Task Unsubscribe(UpdateSubscription subscription) public virtual async Task Unsubscribe(UpdateSubscription subscription)
{ {
log.Write(LogVerbosity.Info, $"Closing subscription {subscription.Id}"); log.Write(LogVerbosity.Info, $"Closing subscription {subscription.Id}");
await subscription.Close(); await subscription.Close().ConfigureAwait(false);
} }
/// <summary> /// <summary>
@ -259,7 +259,7 @@ namespace CryptoExchange.Net
} }
Task.WaitAll(tasks.ToArray()); Task.WaitAll(tasks.ToArray());
}); }).ConfigureAwait(false);
} }
public override void Dispose() public override void Dispose()