chore: Remove Swift 6 warnings

Author: NeedleInAJayStack

Sources/GraphQL/Execution/Values.swift

@@ -88,7 +88,7 @@ func getVariableValue(
     definitionAST: VariableDefinition,
     input: Map
 ) throws -> Map {
-    var type = typeFromAST(schema: schema, inputTypeAST: definitionAST.type)
+    let type = typeFromAST(schema: schema, inputTypeAST: definitionAST.type)
     let variable = definitionAST.variable
 
     guard let inputType = type as? GraphQLInputType else {

Sources/GraphQL/GraphQL.swift

@@ -1,6 +1,6 @@
 import NIO
 
-public struct GraphQLResult: Equatable, Codable, CustomStringConvertible {
+public struct GraphQLResult: Equatable, Codable, Sendable, CustomStringConvertible {
     public var data: Map?
     public var errors: [GraphQLError]
 

Sources/GraphQL/Map/Map.swift

@@ -11,7 +11,7 @@ public enum MapError: Error {
 
 // MARK: Map
 
-public enum Map {
+public enum Map: Sendable {
     case undefined
     case null
     case bool(Bool)
@@ -600,7 +600,7 @@ public extension Map {
     }
 }
 
-extension String: CodingKey {
+extension String: @retroactive CodingKey {
     public var stringValue: String {
         return self
     }

Sources/GraphQL/Map/Number.swift

@@ -1,7 +1,7 @@
 import Foundation
 
-public struct Number {
-    public enum StorageType {
+public struct Number: Sendable {
+    public enum StorageType: Sendable {
         case bool
         case int
         case double

Sources/GraphQL/Utilities/NIO+Extensions.swift

@@ -89,8 +89,8 @@ extension Future {
 
 public protocol FutureType {
     associatedtype Expectation
-    func whenSuccess(_ callback: @escaping (Expectation) -> Void)
-    func whenFailure(_ callback: @escaping (Error) -> Void)
+    func whenSuccess(_ callback: @escaping @Sendable (Expectation) -> Void)
+    func whenFailure(_ callback: @escaping @Sendable (Error) -> Void)
     func map<NewValue>(
         file: StaticString,
         line: UInt,

Tests/GraphQLTests/SubscriptionTests/SubscriptionTests.swift

@@ -28,11 +28,11 @@ class SubscriptionTests: XCTestCase {
               }
         """
 
-        let subscriptionResult = try graphqlSubscribe(
+        let subscriptionResult = try await graphqlSubscribe(
             schema: schema,
             request: query,
             eventLoopGroup: eventLoopGroup
-        ).wait()
+        ).get()
         guard let subscription = subscriptionResult.stream else {
             XCTFail(subscriptionResult.errors.description)
             return
@@ -653,7 +653,7 @@ class SubscriptionTests: XCTestCase {
                 ]]
             )
         )
-        wait(for: [expectation], timeout: timeoutDuration)
+        await fulfillment(of: [expectation], timeout: timeoutDuration)
         XCTAssertEqual(results, expected)
 
         // Low priority email shouldn't trigger an event
@@ -666,7 +666,7 @@ class SubscriptionTests: XCTestCase {
             unread: true,
             priority: 2
         ))
-        wait(for: [expectation], timeout: timeoutDuration)
+        await fulfillment(of: [expectation], timeout: timeoutDuration)
         XCTAssertEqual(results, expected)
 
         // Higher priority one should trigger again
@@ -692,7 +692,7 @@ class SubscriptionTests: XCTestCase {
                 ]]
             )
         )
-        wait(for: [expectation], timeout: timeoutDuration)
+        await fulfillment(of: [expectation], timeout: timeoutDuration)
         XCTAssertEqual(results, expected)
 
         // So that the Task won't immediately be cancelled since the ConcurrentEventStream is
@@ -754,7 +754,7 @@ class SubscriptionTests: XCTestCase {
                 ]]
             )
         )
-        wait(for: [expectation], timeout: timeoutDuration)
+        await fulfillment(of: [expectation], timeout: timeoutDuration)
         XCTAssertEqual(results, expected)
 
         db.stop()
@@ -770,7 +770,7 @@ class SubscriptionTests: XCTestCase {
         ))
 
         // Ensure that the current result was the one before the db was stopped
-        wait(for: [expectation], timeout: timeoutDuration)
+        await fulfillment(of: [expectation], timeout: timeoutDuration)
         XCTAssertEqual(results, expected)
 
         // So that the Task won't immediately be cancelled since the ConcurrentEventStream is
@@ -917,7 +917,7 @@ class SubscriptionTests: XCTestCase {
                 ]]
             )
         )
-        wait(for: [expectation], timeout: timeoutDuration)
+        await fulfillment(of: [expectation], timeout: timeoutDuration)
         XCTAssertEqual(results, expected)
 
         expectation = XCTestExpectation()
@@ -936,7 +936,7 @@ class SubscriptionTests: XCTestCase {
                 ]
             )
         )
-        wait(for: [expectation], timeout: timeoutDuration)
+        await fulfillment(of: [expectation], timeout: timeoutDuration)
         XCTAssertEqual(results, expected)
 
         expectation = XCTestExpectation()
@@ -957,7 +957,7 @@ class SubscriptionTests: XCTestCase {
                 ]]
             )
         )
-        wait(for: [expectation], timeout: timeoutDuration)
+        await fulfillment(of: [expectation], timeout: timeoutDuration)
         XCTAssertEqual(results, expected)
 
         // So that the Task won't immediately be cancelled since the ConcurrentEventStream is