ios – RxSwift:返回一个带有错误的新observable

前端之家收集整理的这篇文章主要介绍了ios – RxSwift:返回一个带有错误的新observable前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
我有一个函数返回Bool Observable,具体取决于它是否正常.
  1. func test() -> Observable<Bool> {
  2. if everythingIsOk {
  3. return just(true)
  4. }
  5. return just(false) <- how can i here return a custom error to retrieve what Failed?
  6. }

解决方法

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

返回包含单个元素的可观察序列.
相反,你应该使用这样的东西:

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

Create方法从指定的subscribe方法实现创建一个可观察的序列.

在你的情况下:

  1. private let realm = try! Realm()
  2.  
  3. func save(customObject: CustomObject) -> Observable<Bool> {
  4. return create({ observer -> Disposable in
  5. do {
  6. try self.realm.write {
  7. self.realm.add(customObject,update: true)
  8. observer.onNext(true)
  9. observer.onCompleted()
  10. }
  11. } catch {
  12. // .Error sequence will be automatically completed
  13. observer.onError(NSError(domai...)
  14. }
  15.  
  16. // if realm.write is sync task(by default it is,as I know) you can actually return NopDisposable
  17. return NopDisposable.instance
  18. // otherwise you should cancel write transaction in AnonymousDisposable
  19. })
  20. }

AnonymousDisposable是在您想要中断的情况下调用的操作.假设您离开视图控制器或应用程序需要完成该服务,您不再需要再调用此请求.它非常适合视频上传或更大的内容.您可以执行request.cancel(),它可以在您完成所有资源后清理它们.在完成或错误调用它.

猜你在找的iOS相关文章