Move local function out to private method

Farfetch · Jul 30, 2024 · 130775a · 130775a
1 parent b1b6dcd
commit 130775a
Showing 1 changed file with 8 additions and 10 deletions.
diff --git a/tests/KafkaFlow.IntegrationTests/ConsumerTest.cs b/tests/KafkaFlow.IntegrationTests/ConsumerTest.cs
@@ -172,7 +172,7 @@ public async Task ManualAssignPartitionOffsetsTest()
             .Without(m => m.Offset)
             .CreateMany(10).ToList();
 
-        messages.ForEach(m => producer.Produce(m.Id.ToString(), m, null, DeliveryHandler));
+        messages.ForEach(m => producer.Produce(m.Id.ToString(), m, null, report => DeliveryHandler(report, messages)));
 
         foreach (var message in messages)
         {
@@ -211,14 +211,12 @@ await serviceProviderHelper.GetServiceProviderAsync(
         }
 
         await serviceProviderHelper.StopBusAsync();
-
-        return;
-
-        void DeliveryHandler(DeliveryReport<byte[], byte[]> report)
-        {
-            var key = Encoding.UTF8.GetString(report.Message.Key);
-            var message = messages.First(m => m.Id.ToString() == key);
-            message.Offset = report.Offset;
-        }
+    }
+
+    private static void DeliveryHandler(DeliveryReport<byte[], byte[]> report, List<OffsetTrackerMessage> messages)
+    {
+        var key = Encoding.UTF8.GetString(report.Message.Key);
+        var message = messages.First(m => m.Id.ToString() == key);
+        message.Offset = report.Offset;
     }
 }