swift - RxSwift 中的乐观 UI 更新

Question

我有一个 View 模型，可以对待办事项数组进行一些更新。我将一组输入映射到操作(建模为枚举中的案例)并将它们合并为一个

let mergedActions = Observable<TodosAction>.merge([
    todosFromService.map { .fromService(todos: $0) },
    toggleFavoriteSubject.map { .toggleFavorite(identifier: $0) },
    toggleIsReadSubject.map { .toggleIsRead(identifier: $0) }
])

然后我使用 scan 来“记住”更新的历史记录。

todos = mergedActions
    .scan([]) { (lastTodos, new) -> [Todo] in
        switch new {
        case .fromService(let todos):
            return todos
        case .toggleFavorite(let identifier):
            return lastTodos.withFavoritedToggled(atId: identifier)
        case .toggleIsRead(let identifier):
            return lastTodos.withIsReadToggled(atId: identifier)
        }
    }

我的问题是将网络请求集成到这种方法中。例如。我有“乐观更新”，我假设成功并更新内存中的待办事项。但我也想在服务器上更新它如果请求失败，则“回滚”该更新。

根据我的可观察对象的当前结构，我无法想到如何做到这一点。例如。 scan 闭包不再存在于 Observables 的世界中，因为它只返回一个 [Todo]，所以我无法使用 flatMap 发出 api 请求或任何东西。

如何修改或增强此功能以支持 api 集成并在远程更新失败时回滚相应的本地更新？

Answer 1

我建议像这个框架那样聚合状态 - https://github.com/maxvol/RaspSwift它还严重依赖 .scan() 运算符，因此您会发现该方法很熟悉。您可以使用它，也可以自己实现类似的解决方案。