RxSwift中repeat-while操作符使用：循环调用API直至返回false

我懂你的困扰——用takeWhile只执行了一次getData，这是因为takeWhile的作用是过滤已有Observable序列中的元素，而不是重复触发源函数的调用。getData(id)本身只会生成一个发射单次Bool值的Observable，所以takeWhile判断完这个值后就结束了，不会再去调用getData。

那该怎么实现循环调用直到返回false呢？推荐用递归+flatMap的方式，每次API请求完成后根据返回结果决定是否继续调用，代码示例如下：

func fetchAllPages(for id: Int) -> Observable<Void> {
    return getData(id: id)
        .flatMap { [weak self] hasMoreData -> Observable<Void> in
            guard let self = self else {
                // 避免循环引用，若self已释放则直接结束
                return Observable.just(())
            }
            
            if hasMoreData {
                // 还有数据，递归调用继续获取下一页
                return self.fetchAllPages(for: id)
            } else {
                // 无更多数据，终止序列
                return Observable.just(())
            }
        }
}

关键细节说明： #

• 递归逻辑：每次getData返回true（还有数据）时，就再次调用fetchAllPages，直到返回false才停止。
• 内存安全：用[weak self]避免递归导致的循环引用，确保当持有该函数的对象（比如ViewController）释放时，序列能正常终止。
• 错误处理：如果getData中发送了error事件，整个序列会立即终止，这符合大多数场景下的错误处理需求；如果需要错误重试，可以在getData或fetchAllPages中添加retry操作符。

为什么不用其他操作符？ #

比如repeatWhen或者generate：

• repeatWhen需要监听重试信号，但不太适合这种“根据前一次结果决定是否继续”的场景；
• generate是同步生成序列的，无法适配异步的API请求，所以递归flatMap是最直接的方案。

内容的提问来源于stack exchange，提问作者Sahbi Belgacem