Rx Programming in Swift (1): Observable and Observer
2026-10-22 19:28:44
在RxSwift中，Observable和Observer是响应式编程的核心概念。Observable代表可观察序列，即数据流，而Observer代表观察者，用于接收和处理Observable发出的事件。以下是对这两个概念的详细解释和示例代码：
1. 创建Observable在RxSwift中，通常不直接继承Observable类来创建自定义的可观察序列，而是使用Observable.create方法来创建。这是因为RxSwift的设计者希望用户通过提供的方法来创建Observable，以确保一致性和安全性。
示例代码：import RxSwiftlet myDataStream = Observable<Int>.create { observer in observer.onNext(1) observer.onNext(2) observer.onNext(3) observer.onCompleted() return Disposables.create()}在这个例子中，我们创建了一个发出整数1、2、3然后完成的Observable序列。observer.onNext(_:)用于发出下一个元素，observer.onCompleted()表示序列结束。
2. 创建Observer在RxSwift中，可以通过多种方式创建观察者。最常见的方式是直接在subscribe方法中使用闭包来处理事件，或者实现ObserverType协议来创建自定义的观察者。
方式一：使用闭包作为观察者myDataStream.subscribe( onNext: { value in print("Received value: (value)") }, onError: { error in print("Received error: (error)") }, onCompleted: { print("Sequence completed") }).disposed(by: disposeBag)方式二：实现ObserverType协议class MyObserver: ObserverType { func on(_ event: Event<Int>) { switch event { case .next(let value): print("MyObserver received value: (value)") case .error(let error): print("MyObserver received error: (error)") case .completed: print("MyObserver sequence completed") } }}let myObserver = MyObserver()myDataStream.subscribe(myObserver).disposed(by: disposeBag)3. 多个观察者订阅同一个Observable一个Observable可以被多个观察者订阅，每个观察者都会独立地接收到Observable发出的所有事件。
示例代码：// 第一个观察者myDataStream.subscribe(onNext: { value in print("Observer 1 received: (value)")}).disposed(by: disposeBag)// 第二个观察者myDataStream.subscribe(onNext: { value in print("Observer 2 received: (value)")}, onCompleted: { print("Observer 2 sequence completed")}).disposed(by: disposeBag)// 第三个观察者（自定义观察者）let customObserver = MyObserver()myDataStream.subscribe(customObserver).disposed(by: disposeBag)4. 运行结果当运行上述代码时，你会看到类似以下的输出（顺序可能有所不同）：
Observer 1 received: 1Observer 1 received: 2Observer 1 received: 3Observer 2 received: 1Observer 2 received: 2Observer 2 received: 3Observer 2 sequence completedMyObserver received value: 1MyObserver received value: 2MyObserver received value: 3MyObserver sequence completed5. 注意事项内存管理：在RxSwift中，通常使用DisposeBag来管理订阅的生命周期，避免内存泄漏。确保在适当的时候调用dispose()或使用disposed(by:)方法。
let disposeBag = DisposeBag()myDataStream.subscribe(...).disposed(by: disposeBag)错误处理：Observable可能会发出错误事件（.error），观察者需要处理这些事件以避免程序意外终止。
完成事件：.completed事件表示Observable正常结束，不会再发出任何事件。
通过以上示例和解释，你应该对RxSwift中的Observable和Observer有了更深入的理解。这两个概念是构建响应式应用程序的基础，掌握它们对于使用RxSwift进行开发至关重要。
热门标签
