Skip to content

Commit c420f0d

Browse files
authored
Enable strict concurrency for NIOPosixTests (#3211)
1 parent ae60dc3 commit c420f0d

3 files changed

Lines changed: 6 additions & 5 deletions

File tree

Package.swift

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -471,7 +471,8 @@ let package = Package(
471471
"CNIOLinux",
472472
"CNIODarwin",
473473
"NIOTLS",
474-
]
474+
],
475+
swiftSettings: strictConcurrencySettings
475476
),
476477
.testTarget(
477478
name: "NIOConcurrencyHelpersTests",

Tests/NIOPosixTests/DatagramChannelTests.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -508,7 +508,7 @@ class DatagramChannelTests: XCTestCase {
508508
// Only run this test on platforms that support recvmmsg: the others won't even
509509
// try.
510510
#if os(Linux) || os(FreeBSD) || os(Android)
511-
final class RecvMmsgHandler: ChannelInboundHandler {
511+
final class RecvMmsgHandler: ChannelInboundHandler, Sendable {
512512
typealias InboundIn = AddressedEnvelope<ByteBuffer>
513513
typealias InboundOut = AddressedEnvelope<ByteBuffer>
514514

Tests/NIOPosixTests/EventLoopFutureTest.swift

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -292,7 +292,7 @@ class EventLoopFutureTest: XCTestCase {
292292
let promises: [EventLoopPromise<Int>] = (0..<100).map { (_: Int) in eventLoop.makePromise() }
293293
let futures = promises.map { $0.futureResult }
294294

295-
let fN: EventLoopFuture<Int> = EventLoopFuture<Int>.reduce(0, futures, on: eventLoop, +)
295+
let fN: EventLoopFuture<Int> = EventLoopFuture<Int>.reduce(0, futures, on: eventLoop) { $0 + $1 }
296296
_ = promises.map { $0.fail(E()) }
297297
XCTAssert(fN.eventLoop === eventLoop)
298298
XCTAssertThrowsError(try fN.wait()) { error in
@@ -311,7 +311,7 @@ class EventLoopFutureTest: XCTestCase {
311311

312312
let futures = promises.map { $0.futureResult }
313313

314-
let fN: EventLoopFuture<Int> = EventLoopFuture<Int>.reduce(0, futures, on: eventLoop, +)
314+
let fN: EventLoopFuture<Int> = EventLoopFuture<Int>.reduce(0, futures, on: eventLoop) { $0 + $1 }
315315
XCTAssert(fN.eventLoop === eventLoop)
316316
XCTAssertThrowsError(try fN.wait()) { error in
317317
XCTAssertNotNil(error as? E)
@@ -327,7 +327,7 @@ class EventLoopFutureTest: XCTestCase {
327327
promises.insert(failedPromise, at: promises.startIndex)
328328

329329
let futures = promises.map { $0.futureResult }
330-
let fN: EventLoopFuture<Int> = EventLoopFuture<Int>.reduce(0, futures, on: eventLoop, +)
330+
let fN: EventLoopFuture<Int> = EventLoopFuture<Int>.reduce(0, futures, on: eventLoop) { $0 + $1 }
331331

332332
failedPromise.fail(E())
333333

0 commit comments

Comments
 (0)