apple/swift-nio-extras
1
0
Fork 0
mirror of https://github.com/apple/swift-nio-extras.git synced 2025-06-01 10:36:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Strict concurrency for NIOHTTPResponsiveness and NIOHTTPResponsivenessTests

Browse Source
This commit is contained in:
George Barnett 2025-03-24 14:23:35 +00:00
parent dc6987e77e
commit 40a1214cba
5 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
Package.swift
View File

@ -229,9 +229,7 @@ var targets: [PackageDescription.Target] = [
.product(name: "HTTPTypes", package: "swift-http-types"),
.product(name: "Algorithms", package: "swift-algorithms"),
],
swiftSettings: [
.enableExperimentalFeature("StrictConcurrency")
]
swiftSettings: strictConcurrencySettings
),
.testTarget(
name: "NIOHTTPResponsivenessTests",
@ -242,9 +240,7 @@ var targets: [PackageDescription.Target] = [
.product(name: "NIOEmbedded", package: "swift-nio"),
.product(name: "HTTPTypes", package: "swift-http-types"),
],
swiftSettings: [
.enableExperimentalFeature("StrictConcurrency")
]
swiftSettings: strictConcurrencySettings
),
]

3
Sources/NIOHTTPResponsiveness/HTTPDrippingDownloadHandler.swift
View File

@ -253,3 +253,6 @@ public final class HTTPDrippingDownloadHandler: ChannelDuplexHandler {
}
}
}
@available(*, unavailable)
extension HTTPDrippingDownloadHandler: Sendable {}

3
Sources/NIOHTTPResponsiveness/HTTPReceiveDiscardHandler.swift
View File

@ -88,3 +88,6 @@ public final class HTTPReceiveDiscardHandler: ChannelInboundHandler {
context.writeAndFlush(self.wrapOutboundOut(.end(nil)), promise: nil)
}
}
@available(*, unavailable)
extension HTTPReceiveDiscardHandler: Sendable {}

3
Sources/NIOHTTPResponsiveness/SimpleResponsivenessRequestMux.swift
View File

@ -143,3 +143,6 @@ public final class SimpleResponsivenessRequestMux: ChannelInboundHandler {
context.writeAndFlush(self.wrapOutboundOut(.end(nil)), promise: nil)
}
}
@available(*, unavailable)
extension SimpleResponsivenessRequestMux: Sendable {}

12
Sources/NIOResumableUploadDemo/main.swift
View File

@ -101,9 +101,11 @@ if #available(macOS 10.15.4, iOS 13.4, watchOS 6.2, tvOS 13.4, *) {
let group = MultiThreadedEventLoopGroup(numberOfThreads: System.coreCount)
let server = try ServerBootstrap(group: group).childChannelInitializer { channel in
channel.pipeline.configureHTTPServerPipeline().flatMap {
channel.pipeline.addHandlers([
HTTP1ToHTTPServerCodec(secure: false),
channel.eventLoop.makeCompletedFuture {
let sync = channel.pipeline.syncOperations
try sync.configureHTTPServerPipeline()
try sync.addHandler(HTTP1ToHTTPServerCodec(secure: false))
try sync.addHandler(
HTTPResumableUploadHandler(
context: uploadContext,
handlers: [
@ -111,8 +113,8 @@ if #available(macOS 10.15.4, iOS 13.4, watchOS 6.2, tvOS 13.4, *) {
directory: URL(fileURLWithPath: CommandLine.arguments[1], isDirectory: true)
)
]
),
])
)
)
}
}
.bind(host: "0.0.0.0", port: 8080)