remove task.run

fanliang11 · Jan 23, 2022 · 5ac4bac · 5ac4bac
1 parent ededd68
commit 5ac4bac
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 18 deletions.
diff --git a/src/Surging.Core/Surging.Core.KestrelHttpServer/DefaultHttpServiceHost.cs b/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);
             };
         }
 

diff --git a/src/Surging.Core/Surging.Core.KestrelHttpServer/HttpServiceHost.cs b/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);
             };
         }
 

diff --git a/src/Surging.Core/Surging.Core.Protocol.Http/HttpServiceHost.cs b/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);
             };
         }