package com.auto.lyric.base.model;
|
|
import androidx.lifecycle.ViewModel;
|
|
import com.auto.lyric.base.activities.BaseActivity;
|
import com.auto.lyric.retrofit.AndroidScheduler;
|
import com.auto.lyric.retrofit.observable.HttpObserver;
|
|
import io.reactivex.Observable;
|
import io.reactivex.schedulers.Schedulers;
|
|
/**
|
* Created by Administrator on 2021/11/11 0011.
|
*/
|
public class BaseViewModel extends ViewModel {
|
|
protected BaseActivity activity;
|
|
public void onCreate(BaseActivity activity){
|
this.activity = activity;
|
}
|
|
/**
|
* 网络请求观察
|
* @param observable
|
* @param <T>
|
* @return
|
*/
|
public <T> void httpObserverOn(Observable<T> observable, HttpObserver observer){
|
observable.subscribeOn(Schedulers.io())//指定网络请求在io后台线程中进行
|
.observeOn(AndroidScheduler.mainThread())
|
.subscribe(observer);
|
}
|
|
|
|
}
|
