如何用RxSwift的Variable根据boxId过滤Realm查询结果？

哦，我明白你的问题了——你现在的代码没办法响应index（也就是boxId）的变化，对吧？因为你在初始化时直接用了index.value，这个值只会被读取一次，之后哪怕index更新了，查询也不会跟着变。而且还要提一句：RxSwift里的Variable已经被废弃啦，现在推荐用BehaviorRelay来实现这类"可变且可观察"的序列。

下面是修改后的完整代码，我会逐段解释关键改动：

import RxSwift
import RxCocoa
import RealmSwift

class MainViewModel { 
    let cases: Driver<[CaseItemViewModel]>
    // 用BehaviorRelay替代废弃的Variable，初始值设为1
    let index = BehaviorRelay<Int>(value: 1)
    
    init() { 
        self.cases = index.asObservable()
            // 每次index变化时，创建新的Realm查询并订阅最新的结果
            .flatMapLatest { boxId in
                // 这里用%@占位符替代字符串拼接，更安全规范
                let caseResults = try! Realm()
                    .objects(RMCase.self)
                    .filter("boxId == %@", boxId)
                    .sorted(byKeyPath: "id", ascending: true)
                
                // 将Realm Results转换为可观察序列，再转为Driver
                return Observable.collection(from: caseResults)
                    .asDriverOnErrorJustComplete()
            }
            // 把Realm查询结果映射成CaseItemViewModel数组
            .map { results in
                results.map { caseObject in
                    // 这里替换成你原来的ViewModel转换逻辑
                    CaseItemViewModel(case: caseObject)
                }
            }
    }
}

关键改动解释： #

• 替换Variable为BehaviorRelay：Variable在RxSwift 4.0后被标记为废弃，BehaviorRelay是BehaviorSubject的安全包装，不会暴露内部的Subject实例，用法更严谨。你可以通过index.accept(newBoxId)来更新boxId的值。
• 监听boxId的变化：通过index.asObservable()订阅boxId的变更，每次值变化都会触发后续的查询逻辑。
• 动态创建Realm查询：在flatMapLatest闭包里，每次拿到新的boxId就生成对应的Realm查询。用%@占位符避免字符串拼接可能带来的问题，这也是Realm查询的推荐写法。
• flatMapLatest的作用：这个操作符会自动取消之前的查询订阅，只保留最新的查询序列，确保UI始终显示与当前boxId匹配的最新结果。
• 序列转换为Driver：最终转为Driver类型，适合绑定到UI组件——Driver默认在主线程发送事件，且通过asDriverOnErrorJustComplete处理了错误场景，避免UI因错误崩溃。

使用方式： #

当你需要切换boxId时，只需要调用：

// 切换到boxId=2的查询
viewModel.index.accept(2)
// 切换回boxId=1的查询
viewModel.index.accept(1)

此时cases这个Driver会自动更新数据，绑定到TableView或CollectionView上就能实时刷新UI啦。

内容的提问来源于stack exchange，提问作者廖豪豪