Add cancellation token to SendNotification* methods

Author: divan

WebPush/WebPushClient.cs

@@ -4,6 +4,7 @@
 using System.Net.Http;
 using System.Net.Http.Headers;
 using System.Runtime.CompilerServices;
+using System.Threading;
 using System.Threading.Tasks;
 using WebPush.Util;
 
@@ -26,14 +27,14 @@ public class WebPushClient : IDisposable
 
         public WebPushClient()
         {
-            
+
         }
 
         public WebPushClient(HttpClient httpClient)
         {
             _httpClient = httpClient;
         }
-        
+
         public WebPushClient(HttpClientHandler httpClientHandler)
         {
             _httpClientHandler = httpClientHandler;
@@ -142,7 +143,7 @@ public HttpRequestMessage GenerateRequestDetails(PushSubscription subscription,
 
             if (options != null)
             {
-                var validOptionsKeys = new List<string> {"headers", "gcmAPIKey", "vapidDetails", "TTL"};
+                var validOptionsKeys = new List<string> { "headers", "gcmAPIKey", "vapidDetails", "TTL" };
                 foreach (var key in options.Keys)
                 {
                     if (!validOptionsKeys.Contains(key))
@@ -181,7 +182,7 @@ public HttpRequestMessage GenerateRequestDetails(PushSubscription subscription,
                     }
 
                     //at this stage ttl cannot be null.
-                    timeToLive = (int) ttl;
+                    timeToLive = (int)ttl;
                 }
             }
 
@@ -257,10 +258,10 @@ public HttpRequestMessage GenerateRequestDetails(PushSubscription subscription,
         ///     notification.
         /// </param>
         public void SendNotification(PushSubscription subscription, string payload = null,
-            Dictionary<string, object> options = null)
+            Dictionary<string, object> options = null, CancellationToken cancellationToken = default)
         {
             var request = GenerateRequestDetails(subscription, payload, options);
-            var sendAsyncTask = HttpClient.SendAsync(request);
+            var sendAsyncTask = HttpClient.SendAsync(request, cancellationToken);
             sendAsyncTask.Wait();
 
             var response = sendAsyncTask.Result;
@@ -277,7 +278,7 @@ public void SendNotification(PushSubscription subscription, string payload = nul
         /// <param name="vapidDetails">The vapid details for the notification.</param>
         public void SendNotification(PushSubscription subscription, string payload, VapidDetails vapidDetails)
         {
-            var options = new Dictionary<string, object> {["vapidDetails"] = vapidDetails};
+            var options = new Dictionary<string, object> { ["vapidDetails"] = vapidDetails };
             SendNotification(subscription, payload, options);
         }
 
@@ -290,7 +291,7 @@ public void SendNotification(PushSubscription subscription, string payload, Vapi
         /// <param name="gcmApiKey">The GCM API key</param>
         public void SendNotification(PushSubscription subscription, string payload, string gcmApiKey)
         {
-            var options = new Dictionary<string, object> {["gcmAPIKey"] = gcmApiKey};
+            var options = new Dictionary<string, object> { ["gcmAPIKey"] = gcmApiKey };
             SendNotification(subscription, payload, options);
         }
 
@@ -305,10 +306,10 @@ public void SendNotification(PushSubscription subscription, string payload, stri
         ///     notification.
         /// </param>
         public async Task SendNotificationAsync(PushSubscription subscription, string payload = null,
-            Dictionary<string, object> options = null)
+            Dictionary<string, object> options = null, CancellationToken cancellationToken = default)
         {
             var request = GenerateRequestDetails(subscription, payload, options);
-            var response = await HttpClient.SendAsync(request);
+            var response = await HttpClient.SendAsync(request, cancellationToken);
 
             HandleResponse(response, subscription);
         }
@@ -323,7 +324,7 @@ public async Task SendNotificationAsync(PushSubscription subscription, string pa
         public async Task SendNotificationAsync(PushSubscription subscription, string payload,
             VapidDetails vapidDetails)
         {
-            var options = new Dictionary<string, object> {["vapidDetails"] = vapidDetails};
+            var options = new Dictionary<string, object> { ["vapidDetails"] = vapidDetails };
             await SendNotificationAsync(subscription, payload, options);
         }
 
@@ -336,7 +337,7 @@ public async Task SendNotificationAsync(PushSubscription subscription, string pa
         /// <param name="gcmApiKey">The GCM API key</param>
         public async Task SendNotificationAsync(PushSubscription subscription, string payload, string gcmApiKey)
         {
-            var options = new Dictionary<string, object> {["gcmAPIKey"] = gcmApiKey};
+            var options = new Dictionary<string, object> { ["gcmAPIKey"] = gcmApiKey };
             await SendNotificationAsync(subscription, payload, options);
         }
 
@@ -354,7 +355,7 @@ private static void HandleResponse(HttpResponseMessage response, PushSubscriptio
             }
 
             // Error
-            var message = @"Received unexpected response code: " + (int) response.StatusCode;
+            var message = @"Received unexpected response code: " + (int)response.StatusCode;
             switch (response.StatusCode)
             {
                 case HttpStatusCode.BadRequest:
@@ -365,7 +366,7 @@ private static void HandleResponse(HttpResponseMessage response, PushSubscriptio
                     message = "Payload too large";
                     break;
 
-                case (HttpStatusCode) 429:
+                case (HttpStatusCode)429:
                     message = "Too many request.";
                     break;
 
@@ -377,7 +378,7 @@ private static void HandleResponse(HttpResponseMessage response, PushSubscriptio
 
             throw new WebPushException(message, response.StatusCode, response.Headers, subscription);
         }
-        
+
         public void Dispose()
         {
             if (_httpClient != null && _isHttpClientInternallyCreated)