讲真,我看了很多 ReactiveX 的文章才看懂这三者。呃,原因是....他们的代码都太长了....我抓不住重点 : (
Functor
Functor 中文名 函子,概念来自于函数式编程。
不少教程都会直接讲
单子,因为它很强大,所以也很难。其实应该从函子讲到应用函子再讲到单子。(功能依次增强)
两篇阮一峰叔叔的文章
可以跑的代码
// 5.kt
import io.reactivex.Maybe
import io.reactivex.rxkotlin.subscribeBy
fun main(args: Array<String>) {
val maybeValue: Maybe<Int> = Maybe.just(14)
maybeValue.subscribeBy(
onComplete = { println("Completed Empty") },
onError = { println("Error $it") },
onSuccess = { println("Completed with value $it") }
)
}
输出
Completed with value 14
再来一个(内容一会说,先看看效果嘛)
// 6.kt
import io.reactivex.Maybe
import io.reactivex.rxkotlin.subscribeBy
fun main(args: Array<String>) {
val maybeEmpty: Maybe<Int> = Maybe.empty()
maybeEmpty.subscribeBy(
onComplete = { println("Completed Empty") },
onError = { println("Error $it") },
onSuccess = { println("Completed with value $it") }
)
}
输出
Completed Empty
我把每个代码段都写完整,因为为了让代码看起来精简而隐去上下文,迫使读者上下前后翻页,会使文章读起来头痛。所以这里面会有一定量样板代码,请谅解。
代码主旨大意
这里面以 Maybe 函子为例(对 你可能还听说过Maybe应用函子 Maybe单子 的说法,因为它是单子,所以自然是函子和应用函子)。它的意思是,一个容器里可能有,也可能没有内容(类似于 Java 的 Optional 和 Scala 的 Option)
在 RxKotlin 中的 Maybe 是可以被订阅的。
以上面的 5.kt 为例,
val maybeValue: Maybe<Int> = Maybe.just(14)
创建了一个名为 maybeValue 的 Maybe 类型的值
maybeValue.subscribeBy(
onComplete = { println("Completed Empty") },
onError = { println("Error $it") },
onSuccess = { println("Completed with value $it") }
)
我们订阅了 maybeValue ,订阅的时候需要三个参数:
- onSuccess: maybeValue 有值的时候调用的函数
- onComplete maybeValue 没有值的时候调用的函数
- onError 出错处理函数
这三个函数只会执行一个,可以参照这个逻辑看一下上面 6.kt 的结果
Observable Observer 与 subscribe
Observable: 可被观察的对象 (在英文里它是一个形容词,为了通顺,在这里用名词~)
Observer: 观察者
subscribe: 订阅
当然我们也可以这么理解
| 名称 | 翻译 | 比喻 |
|---|---|---|
| Observable | 可被观察的对象 | 电台 |
| Observer | 观察者 | 收音机 |
| subscribe | 订阅 | 调节收音机至电台频率 |
是电台发射信号,收音机接收。而不是收音机强迫电台发射信号(Observable 是主动者)
Observable(电台)
基本上不需要手动创建,这里按下不表
Observer(收音机)
一个 Observer 需要实现四个方法
- onNext: Observable 一个接一个地将所有内容传递给该方法。
- onComplete: 当所有内容都处理后调用该方法
- onError: 出错处理函数
- onSubscribe: 开始订阅 Observable 时调用该方法
onError 和 onComplete都是终止方法, 当 onError 被调用时 onComplete 就不会被调用,反之亦然。
例子
下面用到了 object 语法
!!!!之后的所有 Observer 都是这个!!!!
// observer.kt
import io.reactivex.Observer
import io.reactivex.disposables.Disposable
val observer: Observer<Any> = object : Observer<Any> {
override fun onComplete() {
println("All Completed")
}
override fun onNext(item: Any) {
println("Next $item")
}
override fun onError(e: Throwable) {
println("Error Occured ${e.message}")
}
override fun onSubscribe(d: Disposable) {
println("New Subscription ")
}
}
上面仅仅是定义了一个 Observer 没有输出
// 7.kt
import io.reactivex.Observable
import io.reactivex.rxkotlin.toObservable
fun main(args: Array<String>) {
val observable: Observable<Any> = listOf("One", 2, "Three", "Four", 4.5, "Five", 6.0f).toObservable()
// toObservable 见下一节
observable.subscribe(observer)
}
输出
New Subscription
Next One
Next 2
Next Three
Next Four
Next 4.5
Next Five
Next 6.0
All Completed
Observable Observer 与 subscribe 三者的简介就到这里,下一节会展开谈 Observable
RxKotlin 例子不超过15行教程 1----环境配置与初体验
RxKotlin 例子不超过15行教程 2----Observable Observer 与 Subscribe 简介
RxKotlin 例子不超过15行教程 3----Observable 的创建
RxKotlin 例子不超过15行教程 4----Observer Subscribe 与 Hot/Cold Observable
RxKotlin 例子不超过15行教程 5----Subject
RxKotlin 例子不超过15行教程 6----Operator 与 Marble Diagram
RxKotlin 例子不超过15行教程 7----Backpressure Flowable 与 Subscriber 简介
