swift format

Author: sebsto

Sources/AWSLambdaRuntime/Lambda.swift

@@ -41,7 +41,7 @@ public enum Lambda {
         var logger = logger
         do {
             while !Task.isCancelled {
-                
+
                 logger.trace("Waiting for next invocation")
                 let (invocation, writer) = try await runtimeClient.nextInvocation()
                 logger[metadataKey: "aws-request-id"] = "\(invocation.metadata.requestID)"

Sources/AWSLambdaRuntime/LambdaRuntime.swift

@@ -95,29 +95,29 @@ public final class LambdaRuntime<Handler>: Sendable where Handler: StreamingLamb
             guard let port = Int(ipAndPort[1]) else { throw LambdaRuntimeError(code: .invalidPort) }
 
             do {
-            try await LambdaRuntimeClient.withRuntimeClient(
-                configuration: .init(ip: ip, port: port),
-                eventLoop: self.eventLoop,
-                logger: self.logger
-            ) { runtimeClient in
-                try await Lambda.runLoop(
-                    runtimeClient: runtimeClient,
-                    handler: handler,
+                try await LambdaRuntimeClient.withRuntimeClient(
+                    configuration: .init(ip: ip, port: port),
+                    eventLoop: self.eventLoop,
                     logger: self.logger
-                )
-            }
-        } catch {
-            // catch top level errors that have not been handled until now
-            // this avoids the runtime to crash and generate a backtrace
-            self.logger.error("LambdaRuntime.run() failed with error", metadata: ["error": "\(error)"])
-            if let error = error as? LambdaRuntimeError,
-                error.code != .connectionToControlPlaneLost
-            {
-                // if the error is a LambdaRuntimeError but not a connection error,
-                // we rethrow it to preserve existing behaviour
-                throw error
+                ) { runtimeClient in
+                    try await Lambda.runLoop(
+                        runtimeClient: runtimeClient,
+                        handler: handler,
+                        logger: self.logger
+                    )
+                }
+            } catch {
+                // catch top level errors that have not been handled until now
+                // this avoids the runtime to crash and generate a backtrace
+                self.logger.error("LambdaRuntime.run() failed with error", metadata: ["error": "\(error)"])
+                if let error = error as? LambdaRuntimeError,
+                    error.code != .connectionToControlPlaneLost
+                {
+                    // if the error is a LambdaRuntimeError but not a connection error,
+                    // we rethrow it to preserve existing behaviour
+                    throw error
+                }
             }
-        }
 
         } else {
 

Sources/AWSLambdaRuntime/LambdaRuntimeClient.swift

@@ -72,7 +72,7 @@ final actor LambdaRuntimeClient: LambdaRuntimeClientProtocol {
         case lostConnection
         case connecting([ConnectionContinuation])
         case connected(Channel, LambdaChannelHandler<LambdaRuntimeClient>)
-        
+
         static func == (lhs: ConnectionState, rhs: ConnectionState) -> Bool {
             switch (lhs, rhs) {
             case (.disconnected, .disconnected):
@@ -171,7 +171,7 @@ final actor LambdaRuntimeClient: LambdaRuntimeClientProtocol {
 
             case .connected(let channel, _):
                 channel.close(mode: .all, promise: nil)
-            
+
             case .lostConnection:
                 continuation.resume()
             }
@@ -191,7 +191,7 @@ final actor LambdaRuntimeClient: LambdaRuntimeClientProtocol {
                 self.lambdaState = .waitingForNextInvocation
                 let handler = try await self.makeOrGetConnection()
                 let invocation = try await handler.nextInvocation()
-                                
+
                 guard case .waitingForNextInvocation = self.lambdaState else {
                     fatalError("Invalid state: \(self.lambdaState)")
                 }
@@ -320,7 +320,6 @@ final actor LambdaRuntimeClient: LambdaRuntimeClientProtocol {
         case (.connected, .notClosing):
             self.connectionState = .disconnected
 
-
         case (.connected, .closing(let continuation)):
             self.connectionState = .disconnected
 
@@ -394,8 +393,8 @@ final actor LambdaRuntimeClient: LambdaRuntimeClientProtocol {
                 self.assumeIsolated { runtimeClient in
 
                     // resume any pending continuation on the handler
-                    if case .connected(_ , let handler) = runtimeClient.connectionState {
-                        if case .connected(_ , let lambdaState) = handler.state {
+                    if case .connected(_, let handler) = runtimeClient.connectionState {
+                        if case .connected(_, let lambdaState) = handler.state {
                             if case .waitingForNextInvocation(let continuation) = lambdaState {
                                 continuation.resume(throwing: LambdaRuntimeError(code: .connectionToControlPlaneLost))
                             }