forked from swift-server/swift-http-server
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathHTTPService.swift
More file actions
61 lines (57 loc) · 2.13 KB
/
HTTPService.swift
File metadata and controls
61 lines (57 loc) · 2.13 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
//===----------------------------------------------------------------------===//
//
// This source file is part of the Swift HTTP Server open source project
//
// Copyright (c) 2026 Apple Inc. and the Swift HTTP Server project authors
// Licensed under Apache License v2.0
//
// See LICENSE.txt for license information
//
// SPDX-License-Identifier: Apache-2.0
//
//===----------------------------------------------------------------------===//
#if ServiceLifecycle
public import ServiceLifecycle
/// A wrapper over HTTPServer that integrates with ServiceLifecycle.
@available(macOS 26.0, iOS 26.0, watchOS 26.0, tvOS 26.0, visionOS 26.0, *)
public struct HTTPService<
Server: HTTPServer & GracefulShutdownService,
Handler: HTTPServerRequestHandler
>: Service
where
Server.RequestReader == Handler.RequestReader,
Server.ResponseWriter == Handler.ResponseWriter
{
let server: Server
let serverHandler: Handler
let gracefulShutdownHandler: @Sendable () -> Void
/// - Parameters:
/// - server: The underlying HTTPServer instance.
/// - serverHandler: The request handler that `server` will use.
/// - onGracefulShutdown: A closure to execute upon graceful shutdown.
///
/// - Note: The `onGracefulShutdown` closure will be called *after* initiating graceful shutdown on `server`.
public init(
server: Server,
serverHandler: Handler,
onGracefulShutdown gracefulShutdownHandler: @Sendable @escaping () -> Void = {}
) {
self.server = server
self.serverHandler = serverHandler
self.gracefulShutdownHandler = gracefulShutdownHandler
}
/// Runs the HTTP server and handles graceful shutdown when signaled.
public func run() async throws {
try await withGracefulShutdownHandler(
operation: {
try await self.server.serve(handler: self.serverHandler)
},
onGracefulShutdown: {
self.server.beginGracefulShutdown()
// Call the user-provided graceful shutdown handler
self.gracefulShutdownHandler()
}
)
}
}
#endif // ServiceLifecycle