关于CTS项目的Android RxJava和RxAndroid

1、配置build.gradle（Module）
implementation ‘io.reactivex.rxjava2:rxandroid:2.1.0’
implementation ‘io.reactivex.rxjava2:rxjava:2.2.3’

2、测试代码

// Observable  被观察者
// Observer    观察者
// subscribe   订阅
// subscribeOn 指定Observable自身在哪个调度器上执行
// observeOn   指定一个观察者在哪个调度器上观察这个Observable
Observable.just("蒋", "智", "昊", "来", "了")
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                System.out.println("subscribe");
            }

            @Override
            public void onNext(String s) {
                System.out.println(s);
            }

            @Override
            public void onError(Throwable e) {
                System.out.println(e.toString());
            }

            @Override
            public void onComplete() {
                System.out.println("onComplete");
            }
        });

3、结果输出

I/System.out: subscribe
I/System.out: 蒋
智
昊
来
了
onComplete

其他：https://github.com/ReactiveX/RxAndroid