We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0070e39 commit 67910a7Copy full SHA for 67910a7
Sources/AsyncQueue/ActorQueue.swift
@@ -35,10 +35,9 @@ public final class ActorQueue: Sendable {
35
let taskStream = AsyncStream<@Sendable () async -> Void> { continuation in
36
capturedTaskStreamContinuation = continuation
37
}
38
- guard let capturedTaskStreamContinuation else {
39
- fatalError("Continuation not captured during stream creation!")
40
- }
41
- taskStreamContinuation = capturedTaskStreamContinuation
+ // Continuation will be captured during stream creation, so it is safe to force unwrap here.
+ // If this force-unwrap fails, something is fundamentally broken in the Swift runtime.
+ taskStreamContinuation = capturedTaskStreamContinuation!
42
43
streamTask = Task.detached(priority: priority) {
44
actor ActorExecutor {
0 commit comments