allow CancellationToken

Author: Oceania2018

src/Infrastructure/BotSharp.Abstraction/Infrastructures/Events/IEventSubscriber.cs

@@ -1,8 +1,12 @@
+using System.Threading;
+
 namespace BotSharp.Abstraction.Infrastructures.Events;
 
 public interface IEventSubscriber
 {
     Task SubscribeAsync(string channel, Func<string, string, Task> received);
 
-    Task SubscribeAsync(string channel, string group, bool priorityEnabled, Func<string, string, Task> received);
+    Task SubscribeAsync(string channel, string group, bool priorityEnabled, 
+        Func<string, string, Task> received,
+        CancellationToken? stoppingToken = null);
 }

src/Infrastructure/BotSharp.Core/Infrastructures/Events/RedisSubscriber.cs

@@ -25,7 +25,9 @@ await _subscriber.SubscribeAsync(channel, async (ch, message) =>
         });
     }
 
-    public async Task SubscribeAsync(string channel, string group, bool priorityEnabled, Func<string, string, Task> received)
+    public async Task SubscribeAsync(string channel, string group, bool priorityEnabled, 
+        Func<string, string, Task> received, 
+        CancellationToken? stoppingToken = null)
     {
         var db = _redis.GetDatabase();
 
@@ -44,6 +46,12 @@ public async Task SubscribeAsync(string channel, string group, bool priorityEnab
         {
             await Task.Delay(100);
 
+            if (stoppingToken.HasValue && stoppingToken.Value.IsCancellationRequested)
+            {
+                _logger.LogInformation($"Stopping consumer channel & group: [{channel}, {group}]");
+                break;
+            }
+
             if (priorityEnabled)
             {
                 if (await HandleGroupMessage(db, $"{channel}-{EventPriority.High}", group, received) > 0)