我有一个函数返回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?
}
解决方法
just<E>(element: E) -> Observable<E>
返回包含单个元素的可观察序列.
相反,你应该使用这样的东西：
create<E>(subscribe: (AnyObserver<E>) -> Disposable) -> Observable<E>
Create方法从指定的subscribe方法实现创建一个可观察的序列.
在你的情况下：
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(),它可以在您完成所有资源后清理它们.在完成或错误时调用它.
