Update Observable+Result.swift

ivanbruel · Jan 24, 2017 · b983ab4 · b983ab4
1 parent 1f3bb69
commit b983ab4
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/RxResult/Classes/Observable+Result.swift b/RxResult/Classes/Observable+Result.swift
@@ -17,7 +17,11 @@ public extension ObservableType {
 
   public func mapResult<U: RxResultError>(_ errorType: U.Type) -> Observable<Result<E, U>> {
     return self.map(Result<E, U>.success)
-      .catchError{ .just(Result.failure(U.failure(from: $0))) }
+      .catchError{ error in
+        if let error = error as? U {
+            return .just(Result.failure(error))
+        }
+        return .just(Result.failure(U.failure(from: error))) }
     }
 }