File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -32,6 +32,9 @@ public final class AsyncQueue: Sendable {
32
32
let taskStream = AsyncStream < @Sendable ( ) async -> Void > { continuation in
33
33
capturedTaskStreamContinuation = continuation
34
34
}
35
+ guard let capturedTaskStreamContinuation = capturedTaskStreamContinuation else {
36
+ fatalError ( " Continuation not captured during stream creation! " )
37
+ }
35
38
taskStreamContinuation = capturedTaskStreamContinuation
36
39
37
40
streamTask = Task . detached ( priority: priority) {
@@ -85,5 +88,5 @@ public final class AsyncQueue: Sendable {
85
88
// MARK: Private
86
89
87
90
private let streamTask : Task < Void , Never >
88
- private let taskStreamContinuation : AsyncStream < @Sendable ( ) async -> Void > . Continuation !
91
+ private let taskStreamContinuation : AsyncStream < @Sendable ( ) async -> Void > . Continuation
89
92
}
You can’t perform that action at this time.
0 commit comments