Skip to content

Commit 88e24a9

Browse files
committed
Remove unnecessary return
1 parent 1a532c2 commit 88e24a9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Sources/Kafka/KafkaConsumer.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ public struct KafkaConsumerMessages: Sendable, AsyncSequence {
112112
}
113113
#else
114114
// No messages. Sleep a little.
115-
return try await Task.sleep(for: self.pollInterval)
115+
try await Task.sleep(for: self.pollInterval)
116116
#endif
117117
case .suspendPollLoop:
118118
try await Task.sleep(for: self.pollInterval) // not started yet

0 commit comments

Comments
 (0)