作者博客
http://www.jianshu.com/u/c50b715ccaeb
前言
上一节教程讲解了最基本的RxJava2的使用, 在本节中, 我们将学习RxJava强大的线程控制....怎么去理解呢, 以Android为例, 一个Activity的所有动作默认都是在主线程中运行的, 比如我们在onCreate中打出当前线程的名字:
结果便是:
回到RxJava中, 当我们在主线程中去创建一个上游...举个例子:
这段代码中指定了两次上游发送事件的线程, 分别是newThread和IO线程, 下游也指定了两次线程,分别是main和IO线程....因此我们可以在Activity中将这个Disposable 保存起来, 当Activity退出时, 切断它即可....()将它添加到容器中, 在退出的时候, 调用CompositeDisposable.clear() 即可切断所有的水管.