We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1415a54 commit 9966097Copy full SHA for 9966097
RxSwift/Observable+Concurrency.swift
@@ -65,6 +65,7 @@ public extension AsyncSequence {
65
for try await value in self {
66
observer.onNext(value)
67
}
68
+
69
observer.onCompleted()
70
} catch is CancellationError {
71
@@ -74,8 +75,8 @@ public extension AsyncSequence {
74
75
76
77
let task: Task<Void, Never> = detached
- ? Task.detached(operation: taskBlock)
78
- : Task(operation: taskBlock)
+ ? Task.detached(operation: taskBlock)
79
+ : Task(operation: taskBlock)
80
81
return Disposables.create { task.cancel() }
82
0 commit comments