RxJava Single Completable Maybe 使用和源码阅读

Single/SingleObserver

Single 用于只发射一次数据就结束了,所以无需通过 onComplete 通知观察者,要么 onSuccess 要么 onError。

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 方法仍然可用

Single.just("Single just").subscribe(observerSingle)

Completable/CompletableObserver

Completable 不发送数据,只是给观察者发射一个信号,要么 onComplete 要么 onError。

 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 的结合。

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 方法:

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 后也切断了联系。

@Override
public void onComplete() {
  ...
  try {
      actual.onComplete();
  } finally {
      if (d != null) {
          d.dispose();
      }
  }
  ...
}

MaybeCreate 内部的 MaybeEmitter 有和 Single 中相似的 onSuccess 方法,有和 Completable 中相似的 onComplete 方法,无论执行了哪个,在 finally 里都 dispose 切断联系。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏非著名程序员

一次关闭所有Activity和连续点击两次返回键关闭程序的方法

最近有人问我怎么样一次关闭应用程序里所有的Activity的方法,有人说用队列存储的方式,关闭的时候,一个一个的取出再Finish掉。其实个人认为最好的方法就是...

21510
来自专栏向治洪

百度地图聚合

一、牛人们的想法 下面是我参考的有关的博客,下面将一一列举 1.MarkerCluster之百度地图版  http://hi.baidu.com/lion...

8935
来自专栏cmazxiaoma的架构师之路

Android多线程+单线程+断点续传+进度条显示下载

5503
来自专栏飞雪无情的博客

Android Intents and Intent Filters(三)

每个data定义一个URI和数据类型(MIME),URI由4个属性来定义,分别是android:scheme,android:host,android:port...

853
来自专栏Fish

Android判断网络状况

啊,调bug的时候发现在没有网络的时候程序会崩,因此决定加个网络判断的。就是这个代码啦~然后到了要用的时候,new一个类对象调用这个方法就可以了。 packag...

2309
来自专栏Java成神之路

Eclipse插件开发_学习_02_GEF入门实例

(2)搜索 editors,选择 org.eclipse.ui.editors  扩展点,finish

5212
来自专栏Android干货

安卓开发_数据存储技术_外部存储

3338
来自专栏向治洪

Volley解析之表单提交篇

要实现表单的提交,就要知道表单提交的数据格式是怎么样,这里我从某知名网站抓了一条数据,先来分析别人提交表单的数据格式。  数据包: Connection: ...

2295
来自专栏向治洪

系统捕获异常并发送到服务器

大家都知道,现在安装Android系统的手机版本和设备千差万别,在模拟器上运行良好的程序安装到某款手机上说不定就出现崩溃的现象,开发者个人不可能购买所有设备逐个...

2087
来自专栏酷玩时刻

Android版-微信APP支付

服务端源码地址:http://git.oschina.net/javen205/weixin_guide 客户端源码地址:https://github.com...

1.1K2

扫码关注云+社区

领取腾讯云代金券