所以作为一个RxJava2的教程,本文中所有的名词都属于RxJava2中,并不涉及RxJava1。...要在Android中使用RxJava2, 先添加Gradle配置:
正题
在开始学习之前,先来介绍点原理性的东西。...网上也有很多介绍RxJava原理的文章,通常这些文章都从观察者模式开始,先讲观察者,被观察者,订阅关系巴拉巴拉一大堆,说实话,当我第一次看到这些文章的时候已经被这些名词给绕晕了,用了很长的时间才理清楚它们之间的关系...那么在RxJava中怎么去理解它呢, 对应于上面的水管的例子, 我们可以把它理解成两根管道之间的一个机关, 当调用它的dispose()方法时, 它就会将两根管道切断, 从而导致下游收不到事件....来看个例子, 我们让上游依次发送1,2,3,complete,4,在下游收到第二个事件之后, 切断水管, 看看运行结果:
运行结果为:
从运行结果我们看到, 在收到onNext 2这个事件后, 切断了水管