Complete async Observable on CancellationError

ReactiveX · Oct 4, 2024 · ef1d4de · ef1d4de
1 parent 662d91b
commit ef1d4de
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
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)

diff --git a/RxSwift/Traits/PrimitiveSequence/PrimitiveSequence+Concurrency.swift b/RxSwift/Traits/PrimitiveSequence/PrimitiveSequence+Concurrency.swift
@@ -12,7 +12,7 @@ import Foundation
 @available(macOS 10.15, iOS 13.0, watchOS 6.0, tvOS 13.0, *)
 public extension PrimitiveSequenceType where Trait == SingleTrait {
     /**
-     Creates an `Single` from the result of an asynchronous operation
+     Creates a `Single` from the result of an asynchronous operation
 
      - seealso: [create operator on reactivex.io](http://reactivex.io/documentation/operators/create.html)