Single/SingleObserver
Single 用于只发射一次数据就结束了,所以无需通过 onComplete 通知观察者,要么 onSuccess 要么 onError。
代码语言:javascript复制observerSingle = object : SingleObserver<String> {
override fun onSuccess(t: String) {
textView.text = "${textView.text}n $t"
}
override fun onSubscribe(d: Disposable) {
}
override fun onError(e: Throwable) {
}
}
Single.create(SingleOnSubscribe<String> { emitter ->
emitter.onSuccess("single success")
}).subscribe(observerSingle)
just 和 timer 方法仍然可用
代码语言:javascript复制Single.just("Single just").subscribe(observerSingle)
Completable/CompletableObserver
Completable 不发送数据,只是给观察者发射一个信号,要么 onComplete 要么 onError。
代码语言:javascript复制 Completable.create(CompletableOnSubscribe { emitter ->
emitter.onComplete()
}).subscribe(object : CompletableObserver {
override fun onComplete() {
Log.e("RX", "Completable onComplete")
}
override fun onSubscribe(d: Disposable) {}
override fun onError(e: Throwable) {}
})
Maybe/MaybeObserver
Maybe 是 Single 和 Completable 的结合。
代码语言:javascript复制Maybe.create(MaybeOnSubscribe<String> { emitter ->
emitter.onSuccess("maybe success")
emitter.onComplete()
}).subscribe(object : MaybeObserver<String> {
override fun onSuccess(t: String) {
textView.text = "${textView.text}n $t"
}
override fun onComplete() {
textView.text = "${textView.text}n onComplete"
}
override fun onSubscribe(d: Disposable) {
}
override fun onError(e: Throwable) {
}
})
onSuccess 和 onComplete 只能执行一个,即使两个都调用了,比如上面,执行了 onSuccess 后,onComplete 并不能执行到,看源码知道,执行任何一个操作后紧接着就取消订阅了,所以后面一句观察者收不到。
源码分析
和 Observable 源码流程大体相似。
当 SingleObserver 订阅 Single 时,发射 onSuccess 事件,看 SingleCreate 的 onSuccess 方法:
代码语言:javascript复制public void onSuccess(T value) {
...
try {
if (value == null) {
...
} else {
actual.onSuccess(value);
}
} finally {
if (d != null) {
d.dispose();
}
}
...
}
在回调外部观察者的 onSuccess 后,finally 里执行 dispose 方法,切换联系。适合发射一次事件就结束的,即使发多个,由于收到一个就切断了联系,显然不会收到后面发射的。
CompletableCreate 内部的 Emitter 只有 onComplete 和 onError,能发射什么是由这个 Emitter 控制的,在 onComplete 后也切断了联系。
代码语言:javascript复制@Override
public void onComplete() {
...
try {
actual.onComplete();
} finally {
if (d != null) {
d.dispose();
}
}
...
}
MaybeCreate 内部的 MaybeEmitter 有和 Single 中相似的 onSuccess 方法,有和 Completable 中相似的 onComplete 方法,无论执行了哪个,在 finally 里都 dispose 切断联系。