We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 71f18eb commit d496cbbCopy full SHA for d496cbb
Sources/AWSLambdaRuntimeCore/NewLambda.swift
@@ -24,17 +24,17 @@ package protocol StreamingLambdaHandler {
24
) async throws
25
}
26
27
-package enum NewLambda {
+extension Lambda {
28
package static func runLoop<RuntimeClient: LambdaRuntimeClientProtocol, Handler>(
29
runtimeClient: RuntimeClient,
30
handler: Handler,
31
logger: Logger
32
- ) async throws
33
- where Handler: StreamingLambdaHandler {
+ ) async throws where Handler: StreamingLambdaHandler {
+ var handler = handler
34
+
35
while !Task.isCancelled {
36
let (invocation, writer) = try await runtimeClient.nextInvocation()
37
- var handler = handler
38
do {
39
try await handler.handle(
40
invocation.event,
0 commit comments