RxJava超簡單demo

首先導入依賴

compile 'io.reactivex:rxjava:1.0.14'
compile 'io.reactivex:rxandroid:1.0.1'

而後是 觀察者 和被觀察者

//    被觀察者     設置成子線程   進行耗時操做
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> subscriber) {

        subscriber.onNext("第一個事件");
        subscriber.onNext("第二個事件");
        subscriber.onCompleted();
    }
}).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());

//觀察者    讓她運行在主線程裏面，更新UI
Observer<String> observer = new Observer<String>() {
    @Override
    public void onCompleted() {

    }

    @Override
    public void onError(Throwable e) {

    }

    @Override
    public void onNext(String s) {
        Log.e("TAG","--->"+s);
    }
};

最後調用者 關聯 觀察者和被觀察者

observable.subscribe(observer);