RxJava超简单demo

时间 2019-12-01

标签 rxjava 简单 demo 栏目 Java 繁體版

原文原文链接

首先导入依赖java

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

而后是观察者和被观察者react

//    被观察者     设置成子线程   进行耗时操做
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);
    }
};

最后调用者关联观察者和被观察者android

observable.subscribe(observer);