RxSwift核心逻辑-01

RxSwift 的核心内容：

流程图

• Observable - 产生事件
• Observer - 响应事件
• Operator - 创建变化组合事件
• Disposable - 管理绑定（订阅）的生命周期
• Schedulers - 线程队列调配

1. 创建序列 Observerable

        //1.创建序列
       //保存闭包
        let ob = Observable<Int>.create { (observer) -> Disposable in
            return Disposables.create()
        }

create 创建AnonymousObservable类，保存创建序列时的闭包代码块，源码如下：

Create.swift

保存闭包

2.订阅信号

        //2.订阅信号
       ob.subscribe(onNext: { (value) in
            print("订阅到:\(value)")
        }).disposed(by: disposebag)

创建订阅者AnonymousObserver，初始化时保存订阅的闭包
创建AnonymousObservableSink-->sink.run -->AnonymousObservable._subscribeHandler 执行create时的闭包代码，即发送信号

3.发送信号

   let ob = Observable<Int>.create { (observer) -> Disposable in
            //3.发送信号
            observer.onNext(5)
            observer.onCompleted()
//            observer.onError(NSError(domain: "err", code: 1001, userInfo: nil))
            return Disposables.create()
        }

AnonymousObserver.onNext --> ObserverBase.on --> AnonymousObserver.onCore -->执行订阅序列

流程图.png

未完待续。。。。。