diff --git a/RxSwift/RxSwift/Observables/Observable+Multiple.swift b/RxSwift/RxSwift/Observables/Observable+Multiple.swift index 3694334e..f8b01dfc 100644 --- a/RxSwift/RxSwift/Observables/Observable+Multiple.swift +++ b/RxSwift/RxSwift/Observables/Observable+Multiple.swift @@ -61,8 +61,17 @@ public func catch } } +// In case of error, terminates sequence with `replaceErrorWith`. +public func catch + (replaceErrorWith: E) + -> (Observable -> Observable) { + return { source in + return Catch(source: source, handler: { _ in success(returnElement(replaceErrorWith)) }) + } +} + // When error happens `error` will be forwarded as a next `Result` value -// and sequence will be completed +// and sequence will be completed. public func catchToResult (source: Observable) -> Observable> {