RxSwift 冷信号转换成热信号

发表于 2023-10-18 | 分类于 iOS源码探究

Cold Observable 和观察者是一对一的关系，也就是每次产生订阅时，都会是一个新的资料流。而 Hot Observable 和观察者是一对多的关系，也就是每次产生订阅时，都会使用「同一份资料流」，将 Cold Observable 转换成 Hot Observable 的过程，就是将原来的资料流公用。

阅读全文 »

RxSwift 的冷热信号

发表于 2023-10-16 | 分类于 iOS源码探究

了解冷热信号

在探索 RxSwift 的冷热信号之前，我们需要先了解什么是冷热信号。

冷信号	热信号
是被动的，只在被订阅后才发送元素	是主动的，即使没有订阅者，它仍然会时刻推送
只能一对一，当有不同的订阅者，消息是重新完整发送	可以有多个订阅者，是一对多，集合可以与订阅者共享信息
	订阅者在其开始发送元素之后才开始订阅，那么会错过先前发送的所有元素

在前两篇介绍序列的创建与订阅过程中，可以得知 Observable 序列和 Single 序列都是冷信号。从他们的信号发送的过程中，我们也可以看出来，他们都是在被订阅后才开始发送元素，并且有新的订阅者时，消息都是重新发送的。

阅读全文 »

RxSwift 序列的销毁

发表于 2023-10-15 | 分类于 iOS源码探究

序列销毁的两种方式

在前两篇我们注意到，我们在创建一个序列（不论是 Observable 还是 Single 序列）的实现时，都需要返回一个 Disposable 实例。我们已 Observable 序列为例：

阅读全文 »

Single 序列的创建与订阅

发表于 2023-10-14 | 分类于 iOS源码探究

创建一个简单的 single 序列：

func createSingleTest() {
    let single = Single<String>.create { single -> Disposable in
        single(.success("1"))
        
        return Disposables.create()
    }
    
    let _ = single.subscribe { text in
        print("订阅到: \(text)")
    } onFailure: { error in
        print("失败")
    } onDisposed: {
        print("销毁")
    }
}

阅读全文 »

RxSwift 序列的创建与订阅

发表于 2023-10-12 | 分类于 iOS源码探究

创建一个最简单的序列：

func createRxTest() {
    // 1. 创建
    let ob = Observable<String>.create { observer -> Disposable in
        
        // 3. 发送信号
        observer.onNext("1")
        observer.onCompleted()
        
        return Disposables.create()
    }

    // 2. 订阅
    let _ = ob.subscribe(onNext: { (text) in
                print("订阅到: \(text)")
            }, onError: { (error) in
                print("error: \(error)")
            }, onCompleted: {
                print("完成")
            }) {
                print("销毁")
            }
}