问题描述
我有一个函数可以写入/修改数据并返回一个 Observable 来跟踪任务的进度。
func modifyChunk(data: SomeData) -> Observable<Double>
现在在我的用例中，用户可以在运行时随机执行 N 次操作，在那里他可以一遍又一遍地修改相同的数据。我正在寻找一种方法，将新的 Observable 从 modifyChunk(data:) 暂停/推迟到先前存在的 Observable 完成，一旦发生这种情况，立即启动这个新的 Observable，依此类推。
我发现，我可能需要一个队列，在运行时接收 Observable 任务并以 FIFO 方式执行它们。但我不知道如何使用 RxSwift 实现这一点。
解决方法
这听起来像是 concat 的一项工作，它将订阅一个 observable 并等到它完成后再订阅下一个。您没有提供足够的信息，但如果可观察的数量是静态的，那么您可以使用 Observable.concat 运算符。如果 observable 的数量是动态的，那么 concatMap 就是您需要的解决方案。