gradle里面配置

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

//部分代码展示

public void test(){ //创建一个观察者 Observer<Object> observer = new Observer<Object>() { @Override public void onCompleted() { Log.i(TAG, "Completed---"); } @Override public void onError(Throwable e) { Log.i(TAG, "Error"); } @Override public void onNext(Object s) { Log.i(TAG, s.toString()); } }; //使用Observable.create()创建被观察者 Observable observable = Observable.create(new Observable.OnSubscribe<String>() { @Override public void call(Subscriber<? super String> subscriber) { print(subscriber); } }); //创建订阅关系 observable.subscribe(observer); } public void print(Subscriber<? super String> subscriber){ for(int i=0; i<10000; i++){ subscriber.onNext(i + ""); } //这里表示执行结束 subscriber.onCompleted(); }


红色标记表示该耗时操作占用了主线程，所以需要开启一个子线程去执行耗时操作，这里就不写了。