Cosmetic fix.

ordo-one · Aug 28, 2024 · abae3a3 · abae3a3
1 parent f1765b0
commit abae3a3
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 17 deletions.
diff --git a/Sources/Kafka/ForTesting/RDKafkaClient+Group.swift b/Sources/Kafka/ForTesting/RDKafkaClient+Group.swift
@@ -54,24 +54,26 @@ extension RDKafkaClient {
 
             let result = rd_kafka_event_ListConsumerGroups_result(resultEvent)
 
-            var ret = [KafkaGroup]()
             var groupsCnt: size_t = 0
             let groups = rd_kafka_ListConsumerGroups_result_valid(result, &groupsCnt)
-            if let groups {
-                for idx in 0..<groupsCnt {
-                    let group = groups[idx]
-                    let groupId = rd_kafka_ConsumerGroupListing_group_id(group)
-                    guard let groupId else {
-                        throw KafkaError.rdKafkaError(errorMessage: "rd_kafka_ConsumerGroupListing_group_id() unexpectedly returned nil")
-                    }
-                    let kafkaGroupState = rd_kafka_ConsumerGroupListing_state(group)
-                    guard let state = KafkaGroup.State(rawValue: kafkaGroupState.rawValue) else {
-                        throw KafkaError.rdKafkaError(errorMessage: "unexpected value \(kafkaGroupState) for rd_kafka_consumer_group_state_t enumeration")
-                    }
-                    let isSimple = rd_kafka_ConsumerGroupListing_is_simple_consumer_group(group)
-                    let kafkaGroup = KafkaGroup(name: String(cString: groupId), state: state, isSimple: isSimple != 0)
-                    ret.append(kafkaGroup)
+            guard let groups else {
+                return []
+            }
+
+            var ret = [KafkaGroup]()
+            for idx in 0..<groupsCnt {
+                let group = groups[idx]
+                let groupId = rd_kafka_ConsumerGroupListing_group_id(group)
+                guard let groupId else {
+                    throw KafkaError.rdKafkaError(errorMessage: "rd_kafka_ConsumerGroupListing_group_id() unexpectedly returned nil")
+                }
+                let kafkaGroupState = rd_kafka_ConsumerGroupListing_state(group)
+                guard let state = KafkaGroup.State(rawValue: kafkaGroupState.rawValue) else {
+                    throw KafkaError.rdKafkaError(errorMessage: "unexpected value \(kafkaGroupState) for rd_kafka_consumer_group_state_t enumeration")
                 }
+                let isSimple = rd_kafka_ConsumerGroupListing_is_simple_consumer_group(group)
+                let kafkaGroup = KafkaGroup(name: String(cString: groupId), state: state, isSimple: isSimple != 0)
+                ret.append(kafkaGroup)
             }
 
             return ret

diff --git a/Sources/Kafka/KafkaGroup.swift b/Sources/Kafka/KafkaGroup.swift
@@ -14,8 +14,6 @@
 
 import Crdkafka
 
-let uuu: Int = 0
-
 public struct KafkaGroup {
     /// Swift `enum` wrapping `librdkafka`'s `RD_KAFKA_CONSUMER_GROUP_STATE_*` values.
     /// See `rd_kafka_consumer_group_state_t` in rdkafka.h for reference.