如何解决以动态方式顺序运行多个 Observable 实例 | RxSwift
我有一个函数可以写入/修改数据并返回一个 Observable 来跟踪任务的进度。
func modifyChunk(data: SomeData) -> Observable<Double>
现在在我的用例中，用户可以在运行时随机执行 N 次操作，在那里他可以一遍又一遍地修改相同的数据。我正在寻找一种方法，将新的 Observable 从 modifyChunk(data:) 暂停/推迟到先前存在的 Observable 完成，一旦发生这种情况，立即启动这个新的 Observable，依此类推。
我发现，我可能需要一个队列，在运行时接收 Observable 任务并以 FIFO 方式执行它们。但我不知道如何使用 RxSwift 实现这一点。
解决方法
这听起来像是 concat 的一项工作，它将订阅一个 observable 并等到它完成后再订阅下一个。您没有提供足够的信息，但如果可观察的数量是静态的，那么您可以使用 Observable.concat 运算符。如果 observable 的数量是动态的，那么 concatMap 就是您需要的解决方案。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
