feat: Добавил IDisposable

Author: KlinskiyD

src/SignalR.EasyUse.Client/HubConnectionExtensions.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.SignalR.Client;
@@ -38,9 +39,9 @@ public static T CreateNotInheritedHub<T>(this HubConnection hubConnection)
         /// <typeparam name="T">Type of client method</typeparam>
         /// <param name="connection">Connection to the hub that we subscribe to</param>
         /// <param name="action">The action that will be executed when you call the customer</param>
-        public static void Subscribe<T>(this HubConnection connection, Action<T> action) where T : IClientMethod
+        public static IDisposable Subscribe<T>(this HubConnection connection, Action<T> action) where T : IClientMethod
         {
-            SubscribeNotInherited<T>(connection, action);
+           return SubscribeNotInherited<T>(connection, action);
         }
 
         /// <summary>
@@ -50,20 +51,22 @@ public static void Subscribe<T>(this HubConnection connection, Action<T> action)
         /// <typeparam name="T">Type of client method</typeparam>
         /// <param name="connection">Connection to the hub that we subscribe to</param>
         /// <param name="action">The action that will be executed when you call the customer</param>
-        public static void SubscribeNotInherited<T>(this HubConnection connection, Action<T> action)
+        public static IDisposable SubscribeNotInherited<T>(this HubConnection connection, Action<T> action)
         {
             var recieveMessage = typeof(T);
             var methodName = recieveMessage.Name;
             var paramsList = recieveMessage.GetProperties()
                 .Select((info) => info.PropertyType)
                 .ToArray();
 
-            connection.On(methodName, paramsList,
-                objects =>
-                {
-                    var instance = objects.CreateInstance<T>();
-                    return Task.FromResult(action.DynamicInvoke(instance));
-                });
+            IDisposable subscription = connection.On(methodName, paramsList, (object[] args) =>
+            {
+                T instance = args.CreateInstance<T>();
+                action(instance);
+                return Task.CompletedTask;
+            });
+
+            return subscription;
         }
 
         /// <summary>