RxSwift：Return 一个有错误的新可观察对象

Question

我有一个函数 return 一个 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?
}

Answer 1

为了创建可观察对象，有 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


   })
}

Answer 2

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

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

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() ，它会在您完成后清理所有资源。这在完成或错误时被调用。

Answer 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))
}

RxSwift：Return 一个有错误的新可观察对象

RxSwift: Return a new observable with an error

ios

swift

rx-swift