RxSwift 源码解析一：Observable 的创建与订阅

在 RxSwift 中，Observable 是一个强大的工具，它可以用来处理事件流。Observable 的创建和订阅是 RxSwift 的核心概念，理解它们对于使用 RxSwift 至关重要。

Observable 的创建

Observable 可以通过 create 方法来创建。create 方法接收一个闭包作为参数，这个闭包将 Observable 的事件流定义为一个函数。

public class Observable<Element> {
    public static func create(_ subscribe: @escaping (AnyObserver<Element>) -> Disposable) -> Observable<Element> {
        ...
    }
}

在闭包中，你可以通过调用 observer 的 onNext(_:)、onError(_:) 或 onCompleted() 方法来发送事件。

例如，以下代码创建一个 Observable，它每隔一秒发送一个数字：

let observable = Observable<Int>.create { observer in
    var counter = 0
    let timer = DispatchSource.timer(interval: .seconds(1), queue: .main) {
        counter += 1
        observer.onNext(counter)
    }
    timer.resume()

    return Disposables.create {
        timer.cancel()
    }
}

Observable 的订阅

Observable 可以通过 subscribe 方法来订阅。subscribe 方法接收一个闭包作为参数，这个闭包将处理 Observable 发送的事件。

public func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element {
    ...
}

在闭包中，你可以通过实现 ObserverType 协议的方法来处理事件。ObserverType 协议定义了三个方法：

• onNext(_:)：处理正常事件。
• onError(_:)：处理错误事件。
• onCompleted()：处理完成事件。

例如，以下代码订阅了上面的 Observable，并打印收到的数字：

observable.subscribe(onNext: { number in
    print(number)
})

总结

Observable 是 RxSwift 的核心概念，它可以用来处理事件流。Observable 可以通过 create 方法来创建，也可以通过 subscribe 方法来订阅。create 方法接收一个闭包作为参数，这个闭包将 Observable 的事件流定义为一个函数。subscribe 方法接收一个闭包作为参数，这个闭包将处理 Observable 发送的事件。