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());
    }
}