remove next

EasyMicroservices · Oct 26, 2023 · 14fd122 · 14fd122
1 parent f1bb422
commit 14fd122
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/src/CSharp/EasyMicroservices.Laboratory/Engine/Net/Http/HostHttpHandler.cs b/src/CSharp/EasyMicroservices.Laboratory/Engine/Net/Http/HostHttpHandler.cs
@@ -29,7 +29,7 @@ public HostHttpHandler(ResourceManager resourceManager) : base(resourceManager)
         /// <param name="httpClient"></param>
         /// <returns></returns>
         /// <exception cref="NotImplementedException"></exception>
-        protected override async Task HandleHttpClient(HttpContext httpClient)
+        protected override async Task<bool> HandleHttpClient(HttpContext httpClient)
         {
             var reader = new StreamReader(httpClient.Request.Body);
             var requestBody = await reader.ReadToEndAsync();
@@ -63,6 +63,7 @@ protected override async Task HandleHttpClient(HttpContext httpClient)
 
                 await httpClient.Response.Body.WriteAsync(bytes, 0, bytes.Length);
             }
+            return true;
         }
     }
 }

diff --git a/src/CSharp/EasyMicroservices.Laboratory/Engine/Net/Http/HostHttpHandlerBase.cs b/src/CSharp/EasyMicroservices.Laboratory/Engine/Net/Http/HostHttpHandlerBase.cs
@@ -81,8 +81,8 @@ protected virtual async Task InternalStart(int port)
             var app = builder.Build();
             app.Use(async (context, next) =>
             {
-                await HandleHttpClient(context);
-                await next(context);
+                if (!await HandleHttpClient(context))
+                    await next(context);
             });
             await Task.WhenAny(app.RunAsync(null), Task.Delay(3000));
         }
@@ -92,7 +92,7 @@ protected virtual async Task InternalStart(int port)
         /// </summary>
         /// <param name="httpClient"></param>
         /// <returns></returns>
-        protected abstract Task HandleHttpClient(HttpContext httpClient);
+        protected abstract Task<bool> HandleHttpClient(HttpContext httpClient);
 
         string _lastResponseBody = "";
         /// <summary>