关于RxSwift的Observable作用，这篇文章里有详细解释Swift - RxSwift的使用详解3（Observable介绍、创建可观察序列） - 简书。本文不研究使用，只探究原理。
先看一下Observable的效果
输出结果：
订阅到：["1", "2", "3", "4"]
这样就实现了，订阅效果。只要调用onNext，那么sbuscribe的onNext就会被调用。
一：先看一下Observable类是个什么。
点进去查看源码
发现其继承自ObservableType。
二：我们接下来看一下Observable的create。
点进去之后发现，这只是个静态方法，无法进一步查看实现。这时候我们阅读该方法的注释如图：
从注释可以看出，官方给的路由里，有个叫create.html的界面。我们试一下在Rx的源码里，是不是也有一个叫create的文件。
嘿嘿，果然有。点进去这个文件里，映入眼帘的就是我们要找的create方法的声明。
我们发现该方法返回了一个AnonymousObservable对象，并把传进来的闭包作为参数传了进去。
点进AnonymousObservable里，查看
进来之后我们发现，AnonymousObservable类的初始化方法直接保存了传进来的block。这里我们大概也就看到了其用意，因为保存起来之后，后边需要使用的时候直接就能拿来用。注意备注一，后边用的到。
这里我们还应该注意到一个点。AnonymousObservable继承自一个叫Producer的类。这里后面用到再展开。
至此，我们就看到了整个创建的过程。其实就是把create的闭包，保存了起来。
三：我们再看subscribe的实现逻辑。
我们把相对次要的代码删除后的截图如下
实现比较长，我截取核心的几点：
1、方法名。我们发现此方法把所有要实现的block作为参数传了进来。如下
2、核心逻辑。通过截图我们能看到，这里把整个闭包的实现声明成了一个临时变量。不难发现，① 本闭包的核心就是通过event的判断，执行不同的闭包 ；② 我们要调用此闭包，就需要调用observer这个对象。现在关键问题就在于observer调用时机。
3、核心调用。 我们来到return方法。可以发现，在return方法里，把observer作为参数传给了一个叫subscribe的方法。如下图：
另外：asObservable()返回就是自己，见下图。这样做的目的，我猜测可能是为了强调自己是observable。
四：现在就看这个subscribe实现了什么
之前我们提到过，observer的create方法，实际上是返回了一个AnonymousObservable（见图6）。而这个AnonymousObservable则继承自一个叫Producer的东西，我们来看看这个Producer的实现。
看图中的方法一，我们找到了subscribe这个方法。并发现了observer被再次传了出去
往下走，这个run调用的是子类的方法，也就是我们之前的备注一（图7）的方法。我们再来看一下，这段代码：我们发现observer作为AnonymousObservableSink类的参数，参与创建了一个临时变量sink。并执行了sink的run方法。
那么接下来，我们再看一下这个AnonymousObservableSink类的实现，点进去，如下图
我们通过这个run方法可以清楚的看到。这里调用了之前步骤二也就是create方法里保存的那个闭包。并把AnonymousObservableSink作为参数传了进去。
五：由此为什么subscribe能获得onNext的参数的铺垫逻辑，就通顺了
第一步：在创建Observable类的ob对象时，调用的create方法，实际上是保存了我们的create实现的闭包。
第二步：在ob调用subscribe时，已经把订阅的实现逻辑封装到了闭包内，并且把这个闭包封装成了一个叫observer的临时变量，然后调用了AnonymousObservable的subscribe方法。
第三步：AnonymousObservable的subscribe方法，默认创建了AnonymousObservableSink类，并把observer保存成自己属性，又通过该类的run方法调用了第一步里保存的闭包，并把自己作为参数穿进去，用以让第一步保存的闭包成功获得这个observer。
第四步：这样就保证了订阅方法subscribe能获得onNext里的数据。因为subscribe已经持有了Observable创建时声明的闭包。
六：我们再来看这个subscribe到底是怎么获取这个onNext的参数的。
我们再来看一下subscribe的核心实现
我们清晰的看到，只要event是.next事件，那就会调用onNext闭包。关键在于这个event事件是什么时候有的值。那么我们首先想到的是创建ob时onNext的实现是不是给这event赋值了。点进去查看
这里把.next作为参数，调用了一个on方法。我们看这个on方法的实现
看上去感觉这里好像是持有了这个event事件，我们继续点进去查看
我们明显能看到，这个forwardOn方法，是Sink类的方法。而这个sink类就是AnonymousObservableSink的父类。这里确实是用sink持有了这个event。
七：由此我们得出结论。
第一步：在AnonymousObservable类调用subscribe时，实际上是创建了一个sink对象。
第二步：在这个sink类调用我们保存的闭包的时候，也把闭包内的onNext方法方法作为event事件做了持有操作。并在调用observer对象时，把event做为参数传了进来。
第三步：AnonymousObserver类根据传进来的event，调用不同的实现闭包。
附上流程图
