refactor: update batching extension method to AddBatching

Farfetch · Sep 20, 2023 · c07d520 · c07d520
1 parent 22a464b
commit c07d520
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/src/KafkaFlow.UnitTests/BatchConsume/BatchConsumeMiddlewareTests.cs b/src/KafkaFlow.UnitTests/BatchConsume/BatchConsumeMiddlewareTests.cs
@@ -3,7 +3,7 @@ namespace KafkaFlow.UnitTests.BatchConsume
     using System;
     using System.Threading.Tasks;
     using FluentAssertions;
-    using KafkaFlow.Middlewares.BatchConsume;
+    using KafkaFlow.Batching;
     using Microsoft.VisualStudio.TestTools.UnitTesting;
     using Moq;
 

diff --git a/...atchConsume/BatchConsumeMessageContext.cs → ...ow/Batching/BatchConsumeMessageContext.cs b/...atchConsume/BatchConsumeMessageContext.cs → ...ow/Batching/BatchConsumeMessageContext.cs
@@ -1,4 +1,4 @@
-namespace KafkaFlow.Middlewares.BatchConsume
+namespace KafkaFlow.Batching
 {
     using System;
     using System.Collections.Generic;

diff --git a/...es/BatchConsume/BatchConsumeMiddleware.cs → ...kaFlow/Batching/BatchConsumeMiddleware.cs b/...es/BatchConsume/BatchConsumeMiddleware.cs → ...kaFlow/Batching/BatchConsumeMiddleware.cs
@@ -1,4 +1,4 @@
-namespace KafkaFlow.Middlewares.BatchConsume
+namespace KafkaFlow.Batching
 {
     using System;
     using System.Collections.Generic;

diff --git a/...es/BatchConsume/BatchConsumeExtensions.cs → src/KafkaFlow/Batching/BatchingExtensions.cs b/...es/BatchConsume/BatchConsumeExtensions.cs → src/KafkaFlow/Batching/BatchingExtensions.cs
@@ -1,4 +1,4 @@
-namespace KafkaFlow.Middlewares.BatchConsume
+namespace KafkaFlow.Batching
 {
     using System;
     using System.Collections.Generic;
@@ -7,7 +7,7 @@ namespace KafkaFlow.Middlewares.BatchConsume
     /// <summary>
     /// no needed
     /// </summary>
-    public static class BatchConsumeExtensions
+    public static class BatchingExtensions
     {
         /// <summary>
         /// Accumulates a group of messages to be passed as a batch to the next middleware as just one message
@@ -16,7 +16,7 @@ public static class BatchConsumeExtensions
         /// <param name="batchSize">The maximum size of the batch, when this limit is reached the next middleware will be called</param>
         /// <param name="batchTimeout">The maximum time the middleware will wait to call the next middleware</param>
         /// <returns></returns>
-        public static IConsumerMiddlewareConfigurationBuilder BatchConsume(
+        public static IConsumerMiddlewareConfigurationBuilder AddBatching(
             this IConsumerMiddlewareConfigurationBuilder builder,
             int batchSize,
             TimeSpan batchTimeout)
@@ -30,7 +30,7 @@ public static class BatchConsumeExtensions
         }
 
         /// <summary>
-        /// Gets the accumulated <see cref="IMessageContext"/> grouped by BatchConsume middleware
+        /// Gets the accumulated <see cref="IMessageContext"/> grouped by batching middleware
         /// </summary>
         /// <param name="context">The message context</param>
         /// <returns>All the contexts in the batch</returns>