一、描述

指定一个观察者在哪个调度器上观察这个Observable。

很多ReactiveX实现都使用调度器 “Scheduler”来管理多线程环境中Observable的转场。你可以使用ObserveOn操作符指定Observable在一个特定的调度器上发送通知给观察者 (调用观察者的onNext, onCompleted, onError方法)。

注意：当遇到一个异常时ObserveOn会立即向前传递这个onError终止通知，它不会等待慢速消费的Observable接受任何之前它已经收到但还没有发射的数据项。这可能意味着onError通知会跳到（并吞掉）原始Observable发射的数据项前面，正如图例上展示的。

SubscribeOn操作符的作用类似，但它是用于指定Observable本身在特定的调度器上执行，它同样会在那个调度器上给观察者发通知。

RxJava中，要指定Observable应该在哪个调度器上调用观察者的onNext, onCompleted, onError方法，你需要使用observeOn操作符，传递给它一个合适的Scheduler。

二、示意图

observeOn

三、示例代码

System.out.println("ThreadName: " + Thread.currentThread().getName());

Observable.just(1, 2)
    .map(new Func1<Integer, Integer>() {
        @Override
        public Integer call(Integer integer) {
            System.out.println("ThreadName(just): " + Thread.currentThread().getName());
            return integer;
        }
    })
//    .subscribeOn(Schedulers.newThread())
//    .map(new Func1<Integer, Integer>() {
//        @Override
//        public Integer call(Integer integer) {
//            System.out.println("ThreadName(subscribeOn): " + Thread.currentThread().getName());
//            return integer;
//        }
//    })
    .observeOn(Schedulers.newThread())
    .map(new Func1<Integer, Integer>() {
        @Override
        public Integer call(Integer integer) {
            System.out.println("ThreadName(observeOn): " + Thread.currentThread().getName());
            return integer;
        }
    })
    .subscribe(new Subscriber<Integer>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

        @Override
        public void onError(Throwable e) {
            System.out.println("onError: " + e.getMessage());
        }

        @Override
        public void onNext(Integer integer) {
            System.out.println("onNext: " + integer);
        }
    });

四、运行结果

ThreadName: main
ThreadName(just): main
ThreadName(just): main
ThreadName(observeOn): RxNewThreadScheduler-3
onNext: 1
ThreadName(observeOn): RxNewThreadScheduler-3
onNext: 2
onCompleted.