mirror of
https://github.com/swift-server/async-http-client.git
synced 2026-05-03 07:32:29 +00:00
Cory Benfield
50 lines
1.8 KiB
Swift
50 lines
1.8 KiB
Swift
//===----------------------------------------------------------------------===//
|
|
//
|
|
// This source file is part of the AsyncHTTPClient open source project
|
|
//
|
|
// Copyright (c) 2025 Apple Inc. and the AsyncHTTPClient project authors
|
|
// Licensed under Apache License v2.0
|
|
//
|
|
// See LICENSE.txt for license information
|
|
// See CONTRIBUTORS.txt for the list of AsyncHTTPClient project authors
|
|
//
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
//
|
|
//===----------------------------------------------------------------------===//
|
|
// swift-format-ignore
|
|
// Note: Whitespace changes are used to workaround compiler bug
|
|
// https://github.com/swiftlang/swift/issues/79285
|
|
|
|
@inlinable
|
|
@available(macOS 10.15, iOS 13.0, watchOS 6.0, tvOS 13.0, *)
|
|
internal func asyncDo<R>(
|
|
isolation: isolated (any Actor)? = #isolation,
|
|
_ body: () async throws -> sending R,
|
|
finally: sending @escaping ((any Error)?) async throws -> Void
|
|
) async throws -> sending R {
|
|
let result: R
|
|
do {
|
|
result = try await body()
|
|
} catch {
|
|
// `body` failed, we need to invoke `finally` with the `error`.
|
|
|
|
// This _looks_ unstructured but isn't really because we unconditionally always await the return.
|
|
// We need to have an uncancelled task here to assure this is actually running in case we hit a
|
|
// cancellation error.
|
|
try await Task {
|
|
try await finally(error)
|
|
}.value
|
|
throw error
|
|
}
|
|
|
|
// `body` succeeded, we need to invoke `finally` with `nil` (no error).
|
|
|
|
// This _looks_ unstructured but isn't really because we unconditionally always await the return.
|
|
// We need to have an uncancelled task here to assure this is actually running in case we hit a
|
|
// cancellation error.
|
|
try await Task {
|
|
try await finally(nil)
|
|
}.value
|
|
return result
|
|
}
|