Complete async Observable on CancellationError

ReactiveX · Oct 4, 2024 · e0eaead · e0eaead
1 parent 662d91b
commit e0eaead
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/RxSwift/Observable+Concurrency.swift b/RxSwift/Observable+Concurrency.swift
@@ -66,6 +66,8 @@ public extension AsyncSequence {
                         observer.onNext(value)
                     }
 
+                    observer.onCompleted()
+                } catch is CancellationError {
                     observer.onCompleted()
                 } catch {
                     observer.onError(error)