remove task.run

Author: fanliang11

src/Surging.Core/Surging.Core.KestrelHttpServer/DefaultHttpServiceHost.cs

@@ -24,10 +24,7 @@ public DefaultHttpServiceHost(Func<EndPoint, Task<IMessageListener>> messageList
             _serverMessageListener = httpMessageListener;
             _serverMessageListener.Received += async (sender, message) =>
             {
-                await Task.Run(() =>
-                {
-                    MessageListener.OnReceived(sender, message);
-                });
+                 await  MessageListener.OnReceived(sender, message);
             };
         }
 

src/Surging.Core/Surging.Core.KestrelHttpServer/HttpServiceHost.cs

@@ -25,11 +25,8 @@ public HttpServiceHost(Func<EndPoint, Task<IMessageListener>> messageListenerFac
             _messageListenerFactory = messageListenerFactory;
             _serverMessageListener = httpMessageListener;
             _serverMessageListener.Received += async (sender, message) =>
-            {
-                await Task.Run(() =>
-                {
-                    MessageListener.OnReceived(sender, message);
-                });
+            { 
+                 await  MessageListener.OnReceived(sender, message);
             };
         }
 

src/Surging.Core/Surging.Core.Protocol.Http/HttpServiceHost.cs

@@ -46,11 +46,8 @@ public override async Task StartAsync(EndPoint endPoint)
                 return;
             _serverMessageListener = await _messageListenerFactory(endPoint);
             _serverMessageListener.Received += async (sender, message) =>
-            {
-                await Task.Run(() =>
-                {
-                    MessageListener.OnReceived(sender, message);
-                });
+            { 
+                 await   MessageListener.OnReceived(sender, message);
             };
         }
 
@@ -61,10 +58,7 @@ public override async Task StartAsync(string ip,int port)
             _serverMessageListener = await _messageListenerFactory(new IPEndPoint(IPAddress.Parse(ip), AppConfig.ServerOptions.Ports.HttpPort??0));
             _serverMessageListener.Received += async (sender, message) =>
             {
-                await Task.Run(() =>
-                {
-                    MessageListener.OnReceived(sender, message);
-                });
+                await  MessageListener.OnReceived(sender, message);
             };
         }