@@ -123,10 +123,7 @@ final class KafkaTests: XCTestCase {
123123 // Consumer Task
124124 group. addTask {
125125 var consumedMessages = [ KafkaConsumerMessage] ( )
126- for try await messageResult in consumer. messages {
127- guard case let message = messageResult else {
128- continue
129- }
126+ for try await message in consumer. messages {
130127 consumedMessages. append ( message)
131128
132129 if consumedMessages. count >= testMessages. count {
@@ -192,10 +189,7 @@ final class KafkaTests: XCTestCase {
192189 // Consumer Task
193190 group. addTask {
194191 var consumedMessages = [ KafkaConsumerMessage] ( )
195- for try await messageResult in consumer. messages {
196- guard case let message = messageResult else {
197- continue
198- }
192+ for try await message in consumer. messages {
199193 consumedMessages. append ( message)
200194
201195 if consumedMessages. count >= testMessages. count {
@@ -258,10 +252,7 @@ final class KafkaTests: XCTestCase {
258252 // Consumer Task
259253 group. addTask {
260254 var consumedMessages = [ KafkaConsumerMessage] ( )
261- for try await messageResult in consumer. messages {
262- guard case let message = messageResult else {
263- continue
264- }
255+ for try await message in consumer. messages {
265256 consumedMessages. append ( message)
266257 try await consumer. commitSync ( message)
267258
@@ -327,10 +318,7 @@ final class KafkaTests: XCTestCase {
327318 // First Consumer Task
328319 group. addTask {
329320 var consumedMessages = [ KafkaConsumerMessage] ( )
330- for try await messageResult in consumer1. messages {
331- guard case let message = messageResult else {
332- continue
333- }
321+ for try await message in consumer1. messages {
334322 consumedMessages. append ( message)
335323
336324 // Only read first half of messages
@@ -392,10 +380,7 @@ final class KafkaTests: XCTestCase {
392380 // Second Consumer Task
393381 group. addTask {
394382 var consumedMessages = [ KafkaConsumerMessage] ( )
395- for try await messageResult in consumer2. messages {
396- guard case let message = messageResult else {
397- continue
398- }
383+ for try await message in consumer2. messages {
399384 consumedMessages. append ( message)
400385
401386 // Read second half of messages
0 commit comments