Opt into Swift 6 language mode for most targets

Author: fabianfett

Package.swift

@@ -33,8 +33,7 @@ let package = Package(
                 .byName(name: "AWSLambdaRuntimeCore"),
                 .product(name: "NIOCore", package: "swift-nio"),
                 .product(name: "NIOFoundationCompat", package: "swift-nio"),
-            ],
-            swiftSettings: [.swiftLanguageMode(.v5)]
+            ]
         ),
         .target(
             name: "AWSLambdaRuntimeCore",

Sources/AWSLambdaRuntime/Lambda+Codable.swift

@@ -71,7 +71,7 @@ extension LambdaRuntime {
     /// - Parameter encoder: The encoder object that will be used to encode the generic `Output` into a `ByteBuffer`. `JSONEncoder()` used as default.
     /// - Parameter decoder: The decoder object that will be used to decode the incoming `ByteBuffer` event into the generic `Event` type. `JSONDecoder()` used as default.
     public convenience init<Event: Decodable, Output>(
-        body: @escaping (Event, LambdaContext) async throws -> Output,
+        body: sending @escaping (Event, LambdaContext) async throws -> Output,
         encoder: JSONEncoder = JSONEncoder(),
         decoder: JSONDecoder = JSONDecoder()
     )
@@ -97,7 +97,7 @@ extension LambdaRuntime {
     /// - Parameter body: The handler in the form of a closure.
     /// - Parameter decoder: The decoder object that will be used to decode the incoming `ByteBuffer` event into the generic `Event` type. `JSONDecoder()` used as default.
     public convenience init<Event: Decodable>(
-        body: @escaping (Event, LambdaContext) async throws -> Void,
+        body: sending @escaping (Event, LambdaContext) async throws -> Void,
         decoder: JSONDecoder = JSONDecoder()
     )
     where

Sources/AWSLambdaRuntimeCore/Lambda.swift

@@ -60,7 +60,7 @@ public enum Lambda {
     }
 
     /// The default EventLoop the Lambda is scheduled on.
-    public static var defaultEventLoop: any EventLoop = NIOSingletons.posixEventLoopGroup.next()
+    public static let defaultEventLoop: any EventLoop = NIOSingletons.posixEventLoopGroup.next()
 }
 
 // MARK: - Public API

Tests/AWSLambdaRuntimeCoreTests/MockLambdaServer.swift

@@ -27,7 +27,7 @@ func withMockServer<Result>(
     _ body: (_ port: Int) async throws -> Result
 ) async throws -> Result {
     let eventLoopGroup = NIOSingletons.posixEventLoopGroup
-    let server = MockLambdaServer(behavior: behaviour, port: port, keepAlive: keepAlive)
+    let server = MockLambdaServer(behavior: behaviour, port: port, keepAlive: keepAlive, eventLoopGroup: eventLoopGroup)
     let port = try await server.start().get()
 
     let result: Swift.Result<Result, any Error>
@@ -52,7 +52,13 @@ final class MockLambdaServer {
     private var channel: Channel?
     private var shutdown = false
 
-    init(behavior: LambdaServerBehavior, host: String = "127.0.0.1", port: Int = 7000, keepAlive: Bool = true) {
+    init(
+        behavior: LambdaServerBehavior,
+        host: String = "127.0.0.1",
+        port: Int = 7000,
+        keepAlive: Bool = true,
+        eventLoopGroup: MultiThreadedEventLoopGroup
+    ) {
         self.group = NIOSingletons.posixEventLoopGroup
         self.behavior = behavior
         self.host = host
@@ -233,11 +239,14 @@ final class HTTPHandler: ChannelInboundHandler {
             }
         }
 
+        let loopBoundContext = NIOLoopBound(context, eventLoop: context.eventLoop)
+
         context.writeAndFlush(wrapOutboundOut(.end(nil))).whenComplete { result in
             if case .failure(let error) = result {
                 self.logger.error("\(self) write error \(error)")
             }
             if !self.keepAlive {
+                let context = loopBoundContext.value
                 context.close().whenFailure { error in
                     self.logger.error("\(self) close error \(error)")
                 }