android studio 30天学习笔记-day 9-rxjava2补充

昨天介绍rxjava2简单的写法，今天会介绍rxjava2其他的做法

Observables

RxJava提供多种Observables，主要差异在於callback的类型不同，首先:

1.Observable

不支持back pressure，可在onNext(String s)多次执行，完成就调用onComplete()，在onNext(String s)执行期间发生异常则调用onError(Throwable e)

Observable.fromCallable(new Callable<String>() { 
            @Override
            public String call() throws Exception {
                return null;
            }
        }).subscribe(new DisposableObserver<String>() {
            @Override
            public void onNext(String s) {
                
            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onComplete() {

            }
        });

2.Flowable

用法跟Observable差不多，支持back pressure，在被观察者发送事件的速度快於观察者的处理速度时，降低被观察者发送事件的速度。

3.Completable

更新资料时，只需要知道资料的更新是成功或者是失败，无回传值，只处理 onError(Throwable e)或onComplete()的事件

Completable.fromAction(new Action() { 

            @Override
            public void run() throws Exception {

            }
        }).subscribe(new DisposableCompletableObserver() {
            @Override
            public void onComplete() {

            }

            @Override
            public void onError(Throwable e) {

            }
        });

4.Single

回传值成功就调用onSuccess(String s)，否则调用onError(Throwable e)

 Single.fromCallable(new Callable<String>() {
            @Override
            public String call() throws Exception {
                return null;
            }
        }).subscribe(new DisposableSingleObserver<String>() {
            @Override
            public void onSuccess(String s) {

            }

            @Override
            public void onError(Throwable e) {

            }
        });

5.Maybe

onSuccess(String s)接收Maybe发出的数据，完成就调用onComplete()，否则调用onError(Throwable e)
，onSuccess(String s)必须执行於onComplete()跟onError(Throwable e)之前，否则无效。

Maybe.fromCallable(new Callable<String>() {
            @Override
            public String call() throws Exception {
                return null;
            }
        }).subscribe(new DisposableMaybeObserver<String>() {
            @Override
            public void onSuccess(String s) {
                
            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onComplete() {

            }
        });

从上方介绍的Observables中，会发现其中有fromCallable跟fromAction，都是建立要执行的内容，差异是:
fromCallable:有回传值
fromAction:无回传值