swift - 如何在 RxSwift 中从 flatMapLatest 返回不同的类型？

Question

我正在关注 RxSwift 示例 GitHub SignUp using Driver , 并以类似的方式结束。

我有一个执行身份验证并返回 Observable<AuthenticationResult> 的网络请求，这样我就有了:

public enum AuthenticationResult {
    case canceled
    case usernameEmpty
    case passwordEmpty
    case invalidCredentials
    case granted(AccessToken)
    case other(Error)
}

// Authentication result status
let authenticationResult: Driver<AuthenticationResult>

authenticationResult = input.loginTaps.withLatestFrom(usernameAndPassword)
    .flatMapLatest({ (username, password) -> SharedSequence<DriverSharingStrategy, AuthenticationResult> in
        return API.authenticate(username: username, password: password, applicationScope: .property).trackActivity(signingIn).asDriver(onErrorJustReturn: .canceled)
    })
    .flatMapLatest({ (result) -> SharedSequence<DriverSharingStrategy, AuthenticationResult> in

        switch result {

        case .granted(_):
            // The closure is expecting a return value here that I don't have!
            let portfoliosNavigationController = UINavigationController(rootViewController: PortfoliosTableViewController())
            wireframe.show(viewController: portfoliosNavigationController)

        default:

            return wireframe.promptFor(result.description, cancelAction: "OK", actions: [])
                .map({ (_) -> AuthenticationResult in
                    result
                }).asDriver(onErrorJustReturn: result)

        }

    })

现在，问题:

我的 flatMapLatest期望一个 SharedSequence<DriverSharingStrategy, AuthenticationResult>而且我并不总能得到返回!

在闭包内，我可以返回 SharedSequence<DriverSharingStrategy, AuthenticationResult> 如果认证成功，因为我的wireframe.promptFor返回一个可观察对象。

但是，当身份验证失败 时，我没有要返回的可观察对象。我的wireframe.show方法不返回任何内容。

我该如何处理这种情况？

谢谢

Answer 1

假设 switch case .granted 表示身份验证成功，您可以简单地返回 Observable.empty() 或 Driver.empty().

这是做什么的？

通过在 flatMap 操作中返回一个空的驱动程序序列，您的意思是结束可观察序列。流将收到 onCompleted 事件，您可以将其理解为流或操作成功。

您的以下代码将在 drive() 方法的 onCompleted 闭包中找到。

// Your observable stream / driver sequence
.drive(onCompleted: { [unowned wireframe] in

    let portfoliosNavigationController = UINavigationController(rootViewController: PortfoliosTableViewController())

    wireframe.show(viewController: portfoliosNavigationController)

}

这应该有效。

RxCocoa Driver 单元

通过使用 Driver unit ，您是说您期望可观察序列具有以下特征:

• 不能出错
• 观察主调度器
• 分享副作用(shareReplayLatestWhileConnected)

这在执行与 UI 相关的事情时通常很有用(例如你想做的是显示导航 Controller )。如果是这种情况，请继续使用驱动程序。

但是如果我的流可能遇到错误怎么办？

如果有机会你需要返回到一个可观察序列以便你可以出错(因为你将要执行一个可能出错的可观察操作，或者因为你想抛出一个错误来停止操作)，然后您可以在 Driver 实例上使用 toObservable() 操作。

但是要小心，因为你失去了你将在主线程上运行的断言(你需要它来显示 View Controller )。