@@ -123,10 +123,7 @@ final class KafkaTests: XCTestCase {
123
123
// Consumer Task
124
124
group. addTask {
125
125
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 {
130
127
consumedMessages. append ( message)
131
128
132
129
if consumedMessages. count >= testMessages. count {
@@ -192,10 +189,7 @@ final class KafkaTests: XCTestCase {
192
189
// Consumer Task
193
190
group. addTask {
194
191
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 {
199
193
consumedMessages. append ( message)
200
194
201
195
if consumedMessages. count >= testMessages. count {
@@ -258,10 +252,7 @@ final class KafkaTests: XCTestCase {
258
252
// Consumer Task
259
253
group. addTask {
260
254
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 {
265
256
consumedMessages. append ( message)
266
257
try await consumer. commitSync ( message)
267
258
@@ -327,10 +318,7 @@ final class KafkaTests: XCTestCase {
327
318
// First Consumer Task
328
319
group. addTask {
329
320
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 {
334
322
consumedMessages. append ( message)
335
323
336
324
// Only read first half of messages
@@ -392,10 +380,7 @@ final class KafkaTests: XCTestCase {
392
380
// Second Consumer Task
393
381
group. addTask {
394
382
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 {
399
384
consumedMessages. append ( message)
400
385
401
386
// Read second half of messages
0 commit comments