RxJava Single Completable Maybe 使用和源码阅读

2018-09-11 15:56:25 浏览数 (1)

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

0 人点赞