专栏首页三流程序员的挣扎RxJava Single Completable Maybe 使用和源码阅读

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 条评论
登录 后参与评论

相关文章

  • Flutter 学习笔记 12 - 动画 CurvedAnimation

    第二个参数是 Curve 对象,表示动画曲线函数,类似 Android 动画的插值器。有一些内置曲线

    七适散人
  • Flutter 学习笔记 16 - Hero 动画

    七适散人
  • Kail 安装 Parallels Tools 和输入法

    进入 Parallels Tools 目录,执行 ./install 报没有权限的错误。

    七适散人
  • c++ stack / queue 学习笔记

    LRainner
  • 团体程序设计天梯赛-练习集 L1-011 A-B

    本题要求你计算A−B。不过麻烦的是,A和B都是字符串 —— 即从字符串A中把字符串B所包含的字符全删掉,剩下的字符组成的就是字符串A−B。

    C you again 的博客
  • Android项目中文字乱码问题

    Eclipse之所以会出现乱码问题是因为eclipse编辑器选择的编码规则是可变的。一般默认都是UTF-8或者GBK(对于字符编码可参见字符编码的故事),当从外...

    晚晴幽草轩轩主
  • 监控ckeditor内容变化,删除编辑器内图片,ueditor同样适用

    liulun
  • kNN-Iris分类器(一)

    “著名的鸢尾花(Iris)数据集(由Ronald Fisher于1936年发表)是一种展示机器学习框架API的好方法。从某种程度上说,Iris数据集是机器学习界...

    企鹅号小编
  • linux基础命令6

    tr命令 # tr 'a-z' 'A-Z' < /etc/fstab # # /ETC/FSTAB # CREATED BY ANACONDA ON THU ...

    零月
  • Spring Cloud Gateway-ServerWebExchange核心方法与请求或者响应内容的修改

    我们在使用Spring Cloud Gateway的时候,注意到过滤器(包括GatewayFilter、GlobalFilter和过滤器链GatewayFilt...

    Throwable

扫码关注云+社区

领取腾讯云代金券