RxSwift：返回一个带有错误的新可观察对象答案

【问题标题】：RxSwift: Return a new observable with an errorRxSwift：返回一个带有错误的新可观察对象
【发布时间】：2015-12-18 08:48:39
【问题描述】：

我有一个函数返回一个 Bool Observable 取决于它是否正常。

func test() -> Observable<Bool> {
   if everythingIsOk {
      return just(true)
   }
   return just(false) <- how can i here return a custom error to retrieve what failed?
}

【问题讨论】：

return failWith(MyError())

标签： ios swift rx-swift

【解决方案1】：

just<E>(element: E) -> Observable<E>

返回包含单个元素的可观察序列。相反，您应该使用类似的东西：

create<E>(subscribe: (AnyObserver<E>) -> Disposable) -> Observable<E>

Create 方法从指定的订阅方法实现创建一个可观察序列。

在你的情况下：

private let realm = try! Realm()

func save(customObject: CustomObject) -> Observable<Bool> {
    return create({ observer -> Disposable in
        do {
            try self.realm.write {
                self.realm.add(customObject, update: true)
                observer.onNext(true)
                observer.onCompleted()
            }
        } catch {
            // .Error sequence will be automatically completed
            observer.onError(NSError(domai...)
        }

        // if realm.write is sync task(by default it is, as I know) you can actually return NopDisposable
        return NopDisposable.instance
        // otherwise you should cancel write transaction in AnonymousDisposable
    })
}

AnonymousDisposable 是在您想被打断时调用的操作。假设您离开了视图控制器，或者应用程序需要完成服务，并且您不再需要调用此请求。它非常适合视频上传或更大的东西。你可以做 request.cancel() ，它会在你完成后清理所有资源。这会在完成或错误时调用。

【讨论】：

只是想补充一点，根据我的经验，最好将 onNext() 等放在 try 块之外。 Realm 写入实际上不会持续存在，直到它存在该闭包。

【解决方案2】：

create 函数用于创建 observables。你可以这样使用它：

func test() -> Observable<Bool> {
   return create({ (observer) -> Disposable in
//      Some condition
      observer.onNext(true)
//      Some other condition
      observer.onNext(false)
//      Some other condition
      observer.onError(NSError(domain: "My domain", code: -1, userInfo: nil))
//      Some other condition
      observer.onCompleted()

      return AnonymousDisposable {
//         Dispose resources here
      }
//      If u have nothing to dipose use NopDisposable.instance


   })
}

【讨论】：

observer.onNext(true) 和 just(true) 有什么区别
在您的简单示例中没有区别，但在更复杂的示例中，如果您需要进行一些异步工作，例如网络请求或从数据库中获取一些数据，您将无法做到这。并且只是操作员永远不会失败它“只是”发布值，你要发布什么
我不知道你为什么把 .onCompleted() 放在其他条件下，它应该总是被调用，尽管它完成成功或失败？
.onCompleted() 的意思就是你完成了。是的，我的错 :( 。如果订阅中存在它，它将调用 onComplete 回调，并且（以及 onError）在 Disposable 上调用 dispose

【解决方案3】：

使用结果枚举作为您的可观察值。

public enum Result<Value> {
    case success(Value)
    case failure(Error)
}

func test() -> Observable<Result<Bool>> {
   if everythingIsOk {
      return just(.success(true))
   }

   let error = ...
   return just(.failure(error))
}

【讨论】：

observables 应该发送指定类型的值，否则失败。混合 2 是对 observables 概念的否定模式，因为您可以在 onNext 块和 onError 块中收到错误。
您说得对，但在某些情况下您不希望订阅因错误而结束。
您可以使用materialize/dematerialize 或catchError(...)/catchErrorJustReturn(...)。
catchError 和 catchErrorJustReturn 也会发送完成的事件，从而结束订阅。