Use @available for NaiveQueueExecutor

Can't use the current implementation before Swift 6.
swift-server · Nov 14, 2024 · 9c4b7dd · 9c4b7dd
1 parent 5057a20
commit 9c4b7dd
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/Sources/Kafka/KafkaConsumer.swift b/Sources/Kafka/KafkaConsumer.swift
@@ -73,7 +73,9 @@ public struct KafkaConsumerMessages: Sendable, AsyncSequence {
     public struct AsyncIterator: AsyncIteratorProtocol {
         private let stateMachineHolder: MachineHolder
         let pollInterval: Duration
+        #if swift(>=6.0)
         let queue: NaiveQueueExecutor
+        #endif
 
         private final class MachineHolder: Sendable {  // only for deinit
             let stateMachine: LockedMachine
@@ -90,7 +92,9 @@ public struct KafkaConsumerMessages: Sendable, AsyncSequence {
         init(stateMachine: LockedMachine, pollInterval: Duration) {
             self.stateMachineHolder = .init(stateMachine: stateMachine)
             self.pollInterval = pollInterval
+            #if swift(>=6.0)
             self.queue = NaiveQueueExecutor(DispatchQueue(label: "com.swift-server.swift-kafka.message-consumer"))
+            #endif
         }
 
         public func next() async throws -> Element? {

diff --git a/Sources/Kafka/Utilities/NaiveQueueExecutor.swift b/Sources/Kafka/Utilities/NaiveQueueExecutor.swift
@@ -12,6 +12,7 @@
 //
 //===----------------------------------------------------------------------===//
 
+#if swift(>=6.0)
 import Dispatch
 
 final class NaiveQueueExecutor: TaskExecutor {
@@ -35,3 +36,4 @@ final class NaiveQueueExecutor: TaskExecutor {
         UnownedTaskExecutor(ordinary: self)
     }
 }
+#endif