swift - RxSwift 链接请求

Question

我遇到的问题是链接 2 个请求并处理错误。 下面是我的代码示例:

func fbLogin() -> Observable<String> { ... }

func userLogin(request: Request) -> Observable<User> { ... }

let signedWithLogin = loginTaps
    .asDriver(onErrorJustReturn: ())
    .flatMapLatest { _ in
        return fbLogin()
        .map({ ReqestState<String>.loaded($0) })
        .asDriver(onErrorRecover: { error  in
            return Driver.just(.error(error))
        })
        .startWith(.loading)
     }
     .map({ UserEndpoint.socialLogin(token: $0) })
     .flatMapLatest { request in
         return userLogin(request: request)
         .map({ ReqestState<User>.loaded($0) })
         .asDriver(onErrorRecover: { error  in
              return Driver.just(.error(error))
         })
         .startWith(.loading)
     }

signedWithLogin
    .drive(onNext: { response in
        print(response)
     })
    .disposed(by: disposeBag)

问题是当我取消 facebook 登录弹出窗口时，我发送了 observer.onError(FBLoginManagerError.canceled) 错误。此错误首先捕获 .asDriver(onErrorRecover: { error 方法，但不会传递给 .drive(onNext: { response 方法。

如何捕获 .asDriver(onErrorRecover: { error 方法中的所有错误？

Answer 1

Mukesh 是正确的，您可能应该避免 Driver直到最后。此外，同时拥有 RequestState 毫无意义当你只真正关心最后一个时类型 ( RequestState<User> )

这是一个更简单的版本，我认为它可以满足您的需求:

let signedWithLogin = loginTaps
    .flatMapLatest {
        fbLogin()
            .map { UserEndpoint.socialLogin(token: $0) }
            .flatMap { userLogin(request: $0) }
            .map { RequestState.loaded($0) }
            .catchError { .just(.error($0)) }
            .startWith(.loading)
    }
    .asDriver(onErrorRecover: { fatalError($0.localizedDescription) }) // I'm using `fatalError()` here because if the above emits an error something has gone horribly wrong (like the RxSwift library isn't working anymore.)

signedWithLogin
    .drive(onNext: { response in
        print(response)
    })
    .disposed(by: disposeBag)

以上假设您更改了 UserEndpoint.socialLogin(token:)接受字符串而不是 RequestState<String> 的函数.

它还假设 fbLogin()和 userLogin(request:)每个只发出一个值。您可能需要考虑将它们切换为 Single