我有一个返回 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 方法从指定的订阅方法实现创建一个可观察序列。
在你的情况下:
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() ,它会在你完成后清理所有资源。这会在完成或错误时调用。
为了创建 observables,有create
函数。你可以像这样使用它:
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
})
}
Use a result enum as your observable value.
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))
}