RxSwift 初识

RxSwift 中的 Observable 是观察者模式中被观察到对象，相当于一个事件序列，会主动向订阅者发送新产生的事件信息。事件主要分为三类：

• .onNext(element) 表示新的事件数据。
• .onError(error) 表示事件序列因异常而完结
• .onCompleted() 表示事件序列完结。

Subscribe
如果一个 Observable 被创建之后，没有个被任何的订阅者订阅的话，什么事情都不会发生。所以我们需要创建一个订阅者，来响应事件的触发。

_ = Observable<String>.create { observerOfString in
        print("Observable created")
        observerOfString.on(.next("😄"))
        observerOfString.on(.completed)
        return Disposables.create()
    }
    .subscribe { event in
        print(event)
}

通过 subscribe 订阅之后，会收到两个消息 .onNext(element) 和 .onCompleted()打印出：

😄
completed