RX Swift - API 的并行执行答案

【问题标题】：RX Swift - Parallel Execution of APIsRX Swift - API 的并行执行
【发布时间】：2018-12-12 13:33:21
【问题描述】：

我想以某种方式使用 RX，它会从多个 API 下载数据并将它们组合在一起。所有这些都将并行执行，然后合并来自所有响应的数据。我在这里的嵌套调用中执行它们&我想转换代码。

public func searchListings(searchState: SearchState,
                             renderState: SearchRenderState) -  Observable<PropertyNetworkResponse  {
        return Observable.create({ (observer) -  Disposable in

      _ = self.getXData(searchState: searchState, renderState: renderState).subscribe(onNext: { (xData) in

        _ = self.getYData(searchState: searchState, renderState: renderState).subscribe(onNext: { (yData) in

          _ = self.getZData(searchState: searchState, renderState: renderState).subscribe(onNext: { (zData) in

          let results = xData + yData + zData


          observer.onNext(resultNetworkResponse)
          observer.onCompleted()

          }, onError: { (error) in

            observer.onError(error)

          }, onCompleted: nil, onDisposed: nil)
        }, onError: { (error) in

          observer.onError(error)

        }, onCompleted: nil, onDisposed: nil)

      }, onError: { error in

        observer.onError(error)

      }, onCompleted: nil, onDisposed: nil)

      return Disposables.create()   
    }) 
  }

【问题讨论】：

你试过什么？这不是其他人为您工作的平台。

标签： ios swift observable observer-pattern rx-swift

【解决方案1】：

最近我遇到了类似的问题，我能够使用zip 进行并行网络调用。试试下面的代码：

public func searchListings(searchState: SearchState,
                         renderState: SearchRenderState) -  Observable<PropertyNetworkResponse  {

    let observableX = self.getXData(searchState: searchState, renderState: renderState)
    let observableY = self.getYData(searchState: searchState, renderState: renderState)
    let observableZ = self.getZData(searchState: searchState, renderState: renderState)   

    return Observable.create({ (observer) -> Disposable in

        _ = Observable.zip(observableX, observableY, observableZ) { ($0, $1, $2) }
        .subscribe(onNext: { xData, yData, zData in
            let result = xData + yData + zData

            observer.onNext(resultNetworkResponse)
            observer.onCompleted()
        })
        return Disposables.create()   
    }) 
}

请在此link 中查找有关zip 工作原理的信息

【讨论】：