exit from consumer batch loop when no more messages left (#153)

blindspotbounty · web-flow · commit 39876473c390 · 2023-12-01T10:48:19.000Z
diff --git a/Sources/Kafka/KafkaConsumer.swift b/Sources/Kafka/KafkaConsumer.swift
@@ -467,9 +467,10 @@ public final class KafkaConsumer: Sendable, Service {
                 result = .failure(error)
             }
 
-            if let result {
-                messageResults.append(result)
+            guard let result else {
+                return messageResults
             }
+            messageResults.append(result)
         }
 
         return messageResults

Original file line number	Diff line number	Diff line change
`@@ -467,9 +467,10 @@ public final class KafkaConsumer: Sendable, Service {`
`467`	`467`	`result = .failure(error)`
`468`	`468`	`}`
`469`	`469`
`470`		`- if let result {`
`471`		`- messageResults.append(result)`
	`470`	`+ guard let result else {`
	`471`	`+ return messageResults`
`472`	`472`	`}`
	`473`	`+ messageResults.append(result)`
`473`	`474`	`}`
`474`	`475`
`475`	`476`	`return messageResults`