dd

YD_AllHeartRates.Api/Mqtt/MqttBackgroundService.cs

@@ -84,6 +84,9 @@ namespace YD_AllHeartRates.Api.Mqtt
                 return _queue.Writer.WriteAsync(msg, stoppingToken).AsTask();
             };
 
+
+            await foreach (var batch in ReadBatchesAsync(stoppingToken))
+            {
                 List<StudentDto> studentList;
                 List<S_Device> devices;
 
@@ -133,10 +136,6 @@ namespace YD_AllHeartRates.Api.Mqtt
 
                 var studentMap = studentList.GroupBy(x => x.StudentNo).ToDictionary(g => g.Key, g => g.First());
 
-
-            await foreach (var batch in ReadBatchesAsync(stoppingToken))
-            {
-
                 Parallel.ForEach(batch, new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount }, msg =>
                 {
                     try