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

我有一个返回Bool Observable的函数,具体取决于它是否正常.

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

Alexander Gu.. 10

just(element: E) -> Observable

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

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

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

在你的情况下:

private let realm = try! Realm()

func save(customObject: CustomObject) -> Observable {
    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(),它可以在您完成所有资源后清理它们.在完成或错误时调用它.

just(element: E) -> Observable

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

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

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

在你的情况下:

private let realm = try! Realm()

func save(customObject: CustomObject) -> Observable {
    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(),它可以在您完成所有资源后清理它们.在完成或错误时调用它.