RxSwift - 如何顺序链接可观察对象

Question

假设我有整数数组：

var items = [1, 2, 3, 4, 5]

和一个接受 Int 参数并基于它发送网络请求的函数：

 func sendRequest(argument: Int) -> Observable<Void> {
    // sends network request
    ...
 }

我想为 items 数组的每个元素发送网络请求，但我想按顺序执行，只有在前一个请求完成后才发送下一个请求。

我的第一次尝试是这样的：

let observables = items.map{ [weak self] argument in (self?.sendRequest(argument: argument) ?? Observable.empty()) }

let result = Observable.concat(observables)

然而，这种方法同时发送请求并且只按顺序组合结果。

我的第二种方法：

let items = [1, 2, 3, 4, 5]

var result = Observable.just(Void())

for item in items {
    result = result.flatMap{ [weak self] in  
        self?.sendRequest(argument: item) ?? Observable.empty() 
    }
}

它似乎有效，但很明显结果仅在所有网络请求完成后才发出下一个元素。

我需要的是按顺序发送请求，结果可观察到，一旦每个请求完成，就会发出下一个事件。

有什么建议吗？

Answer 1

运算符 .concatMap() 保证顺序保持不变，而不是 .flatMap()

即

Observable.from([1,2,3,4,5]).concatMap( /* your request code */ )

更新

let source = Observable.from([1,2,3,4,5])
let trigger = BehaviorSubject<Int>(value: 0)
let feed = Observable.zip(source, trigger) { return [=11=].0 }

feed.concatMap {
    /* your request code */
    trigger.onNext(0) // possibly in .onComplete of the service call
}

RxSwift - 如何顺序链接可观察对象

RxSwift - how to chain observables sequentially

iphone

observable

ios

swift

rx-swift