Explicitly mark the AsyncSequence iterators as non Sendable (#490)

vapor · Jun 27, 2024 · 200a94a · 200a94a
1 parent f55caa7
commit 200a94a
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 3 deletions.
diff --git a/Package.swift b/Package.swift
@@ -2,7 +2,7 @@
 import PackageDescription
 
 let swiftSettings: [SwiftSetting] = [
-    .enableUpcomingFeature("StrictConcurrency")
+    .enableUpcomingFeature("StrictConcurrency"),
 ]
 
 let package = Package(

diff --git a/Sources/PostgresNIO/New/PostgresNotificationSequence.swift b/Sources/PostgresNIO/New/PostgresNotificationSequence.swift
@@ -20,3 +20,6 @@ public struct PostgresNotificationSequence: AsyncSequence, Sendable {
         }
     }
 }
+
+@available(*, unavailable)
+extension PostgresNotificationSequence.AsyncIterator: Sendable {}
diff --git a/Sources/PostgresNIO/New/PostgresQuery.swift b/Sources/PostgresNIO/New/PostgresQuery.swift
@@ -26,7 +26,7 @@ extension PostgresQuery: ExpressibleByStringInterpolation {
 }
 
 extension PostgresQuery {
-    public struct StringInterpolation: StringInterpolationProtocol {
+    public struct StringInterpolation: StringInterpolationProtocol, Sendable {
         public typealias StringLiteralType = String
 
         @usableFromInline

diff --git a/Sources/PostgresNIO/New/PostgresRowSequence.swift b/Sources/PostgresNIO/New/PostgresRowSequence.swift
@@ -4,7 +4,7 @@ import NIOConcurrencyHelpers
 /// An async sequence of ``PostgresRow``s.
 ///
 /// - Note: This is a struct to allow us to move to a move only type easily once they become available.
-public struct PostgresRowSequence: AsyncSequence {
+public struct PostgresRowSequence: AsyncSequence, Sendable {
     public typealias Element = PostgresRow
 
     typealias BackingSequence = NIOThrowingAsyncSequenceProducer<DataRow, Error, AdaptiveRowBuffer, PSQLRowStream>
@@ -56,6 +56,9 @@ extension PostgresRowSequence {
     }
 }
 
+@available(*, unavailable)
+extension PostgresRowSequence.AsyncIterator: Sendable {}
+
 extension PostgresRowSequence {
     public func collect() async throws -> [PostgresRow] {
         var result = [PostgresRow]()