ios - 使用 RxSwift 处理请求时出错

Question

我有两个可观察对象，第一个检查 AccessToken 是否存在，如果不存在则返回 NotLoggedIn 错误类型。第二个获取用户数据，如果 rx_validate 中的 AccessToken 存在，则应该调用它。但是，我似乎无法弄清楚如何将这些可观察值组合起来，以处理响应中的 rx_fetchUserData 错误。

错误枚举

enum LoginError: Error {
    case NotLoggedIn
    case Unknown
    case NoConnection
}

viewModel 中的可观察对象

// MARK: validate if user is logged in
public func rx_validate() -> Observable<String> {
    return Observable.create({ observer in

        //Check if AccessToken exist
        if let token = AccessToken.current {
            observer.onNext(token.authenticationToken)
            observer.onCompleted()
        } else {
            observer.onError(LoginError.NotLoggedIn)
        }

        return Disposables.create()
    })
}

// MARK: Fetch data
public func rx_fetchUserData(token: String) -> Observable<User> {
    return Network.provider
        .request(.auth(fbToken:  token))
        .retry(1).debug()
        .mapObject(User.self)

}

Answer 1

你应该使用flatMap:

rx_validate()
.flatMap { token in
    return rx_fetchUserData(token: token)
}
.subscribe(onNext: { user in
    // do something with the user  
},
onError: { error in
    // manage errors        
})