Rxjava現在挺火，總的來說就是來解決非同步操作的。
具體詳細解釋，csdn有的是，不贅述，這裡只是提供例子。我也剛接觸，大神勿噴請繞道。

2016-09-13 最簡單的例子（迴圈1秒載入輸出日誌一次），開篇

第一步在你的build.grade裡面的dependencies裡面加上：

compile 'io.reactivex:rxandroid:1.2.1'
compile 'io.reactivex:rxjava:1.1.6'

第二步直接用啦！

Observer<String> observer = new Observer<String>() {
            @Override
 

            public void onNext(String s) {
                new Thread(){
                    public void run() {
                        for (int i = 0;i>=0;i++){
                            try {
                                sleep(1000);
                                Log.d("rxjava", "測試"+i);
                            } catch
 
 (InterruptedException e) {
                                e.printStackTrace();
                            }
                        }
                    }
                }.start();
            }

            @Override
            public void onCompleted() {
                Log.d("rxjava", "Completed!"
 
);
            }

            @Override
            public void onError(Throwable e) {
                Log.d("rxjava", "Error!");
            }
        };

Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
            @Override
            public void call(Subscriber<? super String> subscriber) {
                subscriber.onNext("Hello");
                subscriber.onCompleted();
            }
        });
observable.subscribe(observer);