Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Sources/AWSLambdaRuntime/LambdaRuntimeClient.swift
Original file line number Diff line number Diff line change
Expand Up @@ -514,7 +514,7 @@ private final class LambdaChannelHandler<Delegate: LambdaChannelHandlerDelegate>
"user-agent": .userAgent,
"Lambda-Runtime-Function-Response-Mode": "streaming",
// these are not used by this runtime client at the moment
// FIXME: the eror handling should inject these headers in the streamed response to report mid-stream errors
// FIXME: the error handling should inject these headers in the streamed response to report mid-stream errors
"Trailer": "Lambda-Runtime-Function-Error-Type, Lambda-Runtime-Function-Error-Body",
]
}
Expand Down
2 changes: 1 addition & 1 deletion Tests/AWSLambdaRuntimeTests/LambdaRuntimeClientTests.swift
Original file line number Diff line number Diff line change
Expand Up @@ -299,7 +299,7 @@ struct LambdaRuntimeClientTests {
// simulate traffic until the server reports it has closed the connection
// or a timeout, whichever comes first
// result is ignored here, either there is a connection error or a timeout
let _ = try await timeout(deadline: .seconds(1)) {
let _ = try await withTimeout(deadline: .seconds(1)) {
while true {
let (_, writer) = try await runtimeClient.nextInvocation()
try await writer.writeAndFinish(ByteBuffer(string: "hello"))
Expand Down
2 changes: 1 addition & 1 deletion Tests/AWSLambdaRuntimeTests/Timeout.swift
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
//===----------------------------------------------------------------------===//

// as suggested by https://github.com/vapor/postgres-nio/issues/489#issuecomment-2186509773
func timeout<Success: Sendable>(
func withTimeout<Success: Sendable>(
deadline: Duration,
_ closure: @escaping @Sendable () async throws -> Success
) async throws -> Success {
Expand Down