package com.github.hunter0x7c7.sync.model.server.net.converters;
|
|
import rx.Observable;
|
import rx.schedulers.Schedulers;
|
|
/**
|
* 对服务器请求的Observer的修改
|
*/
|
public class SchedulerTransform<T> implements Observable.Transformer<T, T> {
|
@Override
|
public Observable<T> call(Observable<T> tObservable) {
|
return tObservable
|
.subscribeOn(Schedulers.io())
|
.observeOn(Schedulers.newThread())
|
.unsubscribeOn(Schedulers.io());
|
}
|
}
|
