observeOn()与subscribeOn()的区别

        Observable.just("RxJava")
                .map(new Function<String, String>() {
                    @Override
                    public String apply(@NonNull String s) throws Exception {
                        Log.e("subscribeOn-最初的", Thread.currentThread().getName());
                        return Thread.currentThread().getName();
                    }
                })
                // subscribeOn的调用，改变了调用前序列所运行的线程
                .subscribeOn(AndroidSchedulers.mainThread())
                .map(new Function<String, String>() {
                    @Override
                    public String apply(@NonNull String s) throws Exception {
                        Log.e("subscribeOn-IoScheduler", Thread.currentThread().getName());
                        return Thread.currentThread().getName();
                    }
                })
                // observeOn的调用切换之后的线程
                // observeOn之后，不可再调用subscribeOn 切换线程
                .observeOn(new IoScheduler())
                .map(new Function<String, String>() {
                    @Override
                    public String apply(@NonNull String s) throws Exception {
                        Log.e("observeOn-mainThread", Thread.currentThread().getName());
                        return Thread.currentThread().getName();
                    }
                })
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<String>() {
                    @Override
                    public void accept(String s) throws Exception {
                        Log.e("observeOn-IoScheduler", Thread.currentThread().getName());
                    }
                });