RxJava 1.0版本入门篇之--4

ObserveOn指定观察者所在线程

Observable
.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
//main
Log.i(TAG, "call: "+Thread.currentThread().getName());
subscriber.onNext("Hello Android !");
}
})
.observeOn(Schedulers.io())//设置观察者运行所在的线程
.subscribe(new Action1<String>() {
@Override
public void call(String s) {
//RxIoScheduler-2
Log.i(TAG, "subscribe call: "+Thread.currentThread().getName());
Log.i(TAG, "subscribe call: "+s);
}
});

SubscribeOn指定被观察者所在线程

//subscribeOn让观察者与被观察者运行在特定子线程中
//Schedulers.computation()和Schedulers.io()都是运行在子线程中
//mainThread android的UI线程
Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
Log.v("haha",Thread.currentThread().getName());
subscriber.onNext("Observable");
}
})//.observeOn(Schedulers.io())
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())//运行在主线程中
.subscribe(new Action1<String>() {
@Override
public void call(String s) {

Log.v("haha",Thread.currentThread().getName());
Log.v("haha",s);
}
});