RxSwift 高阶函数：combineLatest 深度剖析

2023-12-18 02:46:49

在 RxSwift 的丰富函数库中，combineLatest 算得上是颗璀璨的明珠。它使开发者能够优雅地将多个序列合并为一个，让观察者仅在所有输入序列同时发出元素时才会收到通知。深入了解 combineLatest 的奥秘，将帮助您掌握 RxSwift 的进阶用法，构建更复杂、更具响应性的应用程序。

combineLatest 的本质

combineLatest 函数属于 RxSwift 中的高阶函数范畴，顾名思义，它可以将多个序列（即 Observable）组合成一个新的序列。当所有输入序列同时发出元素时，combineLatest 会将这些元素组合成一个元组，并将其作为新的序列中的一个元素发出。

let observable1 = Observable.of(1, 2, 3)
let observable2 = Observable.of("a", "b", "c")

let combined = Observable.combineLatest(observable1, observable2) { (number, letter) in
    "\(number) - \(letter)"
}

combined.subscribe { event in
    print(event)
}

在上面的示例中，combineLatest 会组合 observable1 和 observable2，并输出以下序列：

1 - a
2 - b
3 - c

combineLatest 的实现

要深入理解 combineLatest 的运作原理，需要探究其源码。combineLatest 的实现位于 CombineLatest+arity.swift 文件中。它采用泛型函数 combineLatest 的形式，允许组合任意数量的序列。

public static func combineLatest<O1 : ObservableConvertibleType, O2 : ObservableConvertibleType>(
    _ source1: O1,
    _ source2: O2
) -> Observable<CombineLatestSequence<O1.Element, O2.Element>> { ... }