Observable<Observable<T>> 到 Observable<T> rxswift

Question

您好，我很难弄清楚这一点。 还有一些其他问题。

谁能帮我把Observable<[Observable<CellModel>]变成Observable<[CellModel]>?

request(categoryId: $0) 的结果是 Observable<[Observable<CellModel>?]>

enter image description here

  selectCategory
        .do(onNext: { _ in output.cells.onNext([.init(cellID: kSkeletonTableID)]) })
        .flatMap { [unowned self] in request(categoryId: $0) }
       // .showIndicator()
        .trackError(errorTracker)
        .compactMap {
            var cellModel:[CellModel] = $0.flatMap { $0 }
            return cellModel
        }
        .bind(to: output.cells)
        .disposed(by: disposeBag)

Answer 1

这是你从request(categoryId:) 返回的一个相当受折磨的类型。真正的解决办法就在那里。然而，这个问题的答案是：

selectCategory
    .do(onNext: { _ in output.cells.onNext([.init(cellID: kSkeletonTableID)]) })
    .flatMap { request(categoryId: $0).flatMap { Observable.combineLatest($0.compactMap { $0 }) } }
    // .showIndicator()
    .trackError(errorTracker)
    .bind(to: output.cells)
    .disposed(by: disposeBag)

您可能需要根据预期输出考虑 flatMap 的其他变体之一。详情见这篇文章：RxSwift's Many Faces of FlatMap