RxJava尝试取代Handler初探

在之前的一篇文章中，我们探究了RxJava的使用方法，详细请看https://www.cnblogs.com/yanyojun/p/9745675.html

根据扔物线大神的描述，如果用一个词来概括RxJava，那就是“异步”，确实，几乎上能用Handler+Thread进行异步逻辑处理都能用RxJava处理。但是实际上，Handler在临床上不仅用于异步通信，看下面一个例子。

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        mHandler.post(() -> {
            log("mhandler post"); //我们希望后执行这部分逻辑
        });
        log("over"); //我们希望先执行这部分逻辑
    }

如上述代码，我们希望over和mHandler post两个日志都在主线程中打印出来，其中，先打印over，后打印mHandler post。但是mhandler post的代码必须在over前面。这个时候我们就可以借助Handler进行实现。

Handler会将要执行的代码放到消息队列中，等待主线程空闲的时候再取出来执行。

那RxJava能否可以实现呢？

答案必须是可以的，看下面代码：

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        rx.Observable.empty()
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Subscriber<Object>() {
                    @Override
                    public void onCompleted() {
                        log("onCompleted");
                    }

                    @Override
                    public void onError(Throwable e) {
                        log("onError");
                    }

                    @Override
                    public void onNext(Object o) {
                        log("onNext");
                    }
                });40         log("over");

    }

这里有一个坑需要注意下，必须设置 .observeOn(AndroidSchedulers.mainThread()) 否则的话，还是会先打印onCompleted，最后打印over的。切记切记。