Skip to content

Commit 8931930

Browse files
committed
fix for swift-async-queue API changes
1 parent 11637bc commit 8931930

File tree

3 files changed

+14
-14
lines changed

3 files changed

+14
-14
lines changed

Package.resolved

Lines changed: 10 additions & 10 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Package.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ let package = Package(
4949
dependencies: [
5050
.package(url: "https://github.com/apple/swift-async-algorithms", from: "1.0.0"),
5151
.package(url: "https://github.com/lhoward/AsyncExtensions", from: "0.9.0"),
52-
.package(url: "https://github.com/dfed/swift-async-queue", from: "0.4.0"),
52+
.package(url: "https://github.com/dfed/swift-async-queue", from: "0.7.0"),
5353
.package(url: "https://github.com/apple/swift-log", from: "1.6.2"),
5454
.package(url: "https://github.com/apple/swift-system", from: "1.0.0"),
5555
.package(url: "https://github.com/PADL/SocketAddress", from: "0.0.1"),
@@ -65,7 +65,7 @@ let package = Package(
6565
cSettings: [
6666
.define("_XOPEN_SOURCE=700"),
6767
.define("_DEFAULT_SOURCE"),
68-
.define("\(cqHandlerType.rawValue)=1")
68+
.define("\(cqHandlerType.rawValue)=1"),
6969
],
7070
cxxSettings: [
7171
.define("_XOPEN_SOURCE=700"),

Sources/IORing/SubmissionGroup.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ actor SubmissionGroup<T: Sendable> {
5656
///
5757
func enqueue(submission: SingleshotSubmission<T>) {
5858
submissions.append(submission)
59-
queue.enqueue { _ in
59+
Task(on: queue) { _ in
6060
await submission.enqueue()
6161
}
6262
}
@@ -81,7 +81,7 @@ actor SubmissionGroup<T: Sendable> {
8181
/// - Collect results from results channel
8282
///
8383
func finish() async throws -> [T] {
84-
await queue.enqueueAndWait { _ in }
84+
await Task(on: queue) { _ in }.value
8585
await allReady()
8686
try await ring.submit()
8787
readinessChannel.finish()

0 commit comments

Comments
 (0)