liveDataCallAdapter库 用来实现Retrofit+LiveData具有生命周期的网络请求
关于添加引用使用 （支持Java/Kotlin）
关于
因为最近在用java写一个模仿网易云音乐的博客教程，所以用到了retrofit+rxjava+okhttp3网络框架，因为项目是mvvm框架，所以难免会用到LiveData，它的优势如下： 所以也推荐用LiveData，使用rxjava也可以，就是要考虑一些内存泄漏等问题。
添加引用
liveDataCallAdapter 工程build：
allprojects {
repositories {
...
maven { url 'https://jitpack.io' }
}
}
项目build：
implementation 'com.github.Tobeyr1:liveDataCallAdapter:1.0.2'
使用 （支持Java/Kotlin）
将其添加到你的retrofit的build中：
Retrofit.Builder()
.client(client)
.baseUrl(Constant.BaseUrl)
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.addCallAdapterFactory(LiveDataCallAdapterFactory.create()) //add this line to you httpService
.addConverterFactory(GsonConverterFactory.create())
.build();
修改调用api的地方：
@GET("lyric") //获取歌词
LiveData
//默认使用方法是LiveData
然后在页面中使用：
viewModel.getLyric(1111111)
//lyricEntityApiResponse是根据你的实体类和lib中的apiResonse合成的
.observe(this, lyricEntityApiResponse -> {
//可以通过提供的getStatus()方法来判断是返回成功了，还是失败 Status.SUCCESS Status.ERROR
//如果失败了，也可以通过getMessage()获取失败信息
//通过getData()获取实体类数据
if (lyricEntityApiResponse.getStatus() == Status.SUCCESS){
binding.lrc.loadLrc(lyricEntityApiResponse.getData().getLrc().getLyric(),lyricEntityApiResponse.getData().getTlyric().getLyric());
}
});
因为是livedata，所以我们可以在这里嵌套调用其他方法，比如请求b的参数基于请求a的结果，但是可以把耗时操作放到viewmodel里面。 相比较rxjava的调用方式：
viewModel.login()
.compose(RXHelper.observableIO2Main(this))
.subscribe(new Observer
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(LoginEntity login_bean) {
if (login_bean.getCode() == 200) {
} else {
}
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {}
});
其中RXHelper.java代码如下：
public class RXHelper {
public static
return upstream -> {
Observable
.observeOn(AndroidSchedulers.mainThread());
return composeContext(context, observable);
};
}
public static
return upstream -> upstream.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread()).compose(fragment.
}
public static
return upstream -> upstream
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}
private static
if(context instanceof RxActivity) {
return observable.compose(((RxActivity) context).bindUntilEvent(ActivityEvent.DESTROY));
} else if(context instanceof RxFragmentActivity){
return observable.compose(((RxFragmentActivity) context).bindUntilEvent(ActivityEvent.DESTROY));
}else if(context instanceof RxAppCompatActivity){
return observable.compose(((RxAppCompatActivity) context).bindUntilEvent(ActivityEvent.DESTROY));
}else {
return observable;
}
}
}
参考文章
您阅读本篇文章共花了：
发表评论