kotlin - 在 kotlin 中使用 Mvvm 和 Retrofit 和 Rxjava 实时数据的问题
问题描述
我是 kotlin 的新手,我正在尝试使用 Rxjava 和 MVVM 架构中的实时数据进行改造。我配置改造,并在 ViewModel 中使用 observable 和 subscribe 来制作 observable 变量以在活动绑定布局中使用。我的视图中有一个按钮,当我单击它时,请求方法开始启动并订阅写入自己的数据日志。但是我的变量一开始和几秒钟后变为空,当改造完成其任务时,我的变量获取数据但日志值不更新。
这是我的改造初始化类
class ApiService {
private val INSTANCE =
Retrofit.Builder()
.baseUrl("http://www.janbarar.ir/App/")
.addConverterFactory(GsonConverterFactory.create())
.build()
.create(IRetrofitMethods::class.java)
private fun <T> callBack(iDataTransfer: IDataTransfer<T>) =
object : Callback<T> {
override fun onResponse(call: Call<T>, response: Response<T>) {
val data = response.body()
if (data != null)
iDataTransfer.onSuccess(data)
else
try {
throw Exception("data is empty")
} catch (ex: Exception) {
iDataTransfer.onError(ex)
}
}
override fun onFailure(call: Call<T>, t: Throwable) {
iDataTransfer.onError(t)
}
}
fun getCategories(iDataTransfer: IDataTransfer<List<Category>>) =
INSTANCE.getCategories().enqueue(callBack(iDataTransfer))
这是一个改造界面
@GET("GetCategories")
fun getCategories(): Call<List<Category>>
这是我的模型课。我认为问题就在这里。因为可观察对象在改造完成其工作之前发送空数据。
fun getCategories(): Observable<ArrayList<Category>> {
val result = arrayListOf<Category>()
api.getCategories(object : IDataTransfer<List<Category>> {
override fun onSuccess(data: List<Category>) {
result.addAll(data)
}
override fun onError(throwable: Throwable) {
Log.e("Model", throwable.message!!)
}
})
return Observable.just(result)
}
这也是我的 ViewModel 类
class ProductViewModel(private val model: ProductModel) : ViewModel() {
var isLoading = ObservableField(false)
var categoryList = MutableLiveData<ArrayList<Category>>()
private var compositeDisposable = CompositeDisposable()
fun getCategories() {
isLoading.set(true)
compositeDisposable +=
model.getCategories()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe({
categoryList.value = it
}, {
Log.e("ViewModel", it.message.toString())
})
isLoading.set(false)
}
最后,这是我的活动
lateinit var binding: ActivityMainBinding
private val vm: ProductViewModel by viewModel()
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
binding = DataBindingUtil.setContentView(this, R.layout.activity_main)
binding.vm = vm
vm.categoryList.observe(this, Observer {
if (it != null)
Log.e("activity", it.toString())
})
}
解决方案
正如 ExpensiveBelly 在评论中提到的,Retrofit 为 RxJava 提供了一个调用适配器,因此您可以让您的 APIObservable<List<Category>>
直接返回。为此,您需要将 RxJava 调用适配器依赖项添加到您的应用程序模块的build.gradle
:
implementation 'com.squareup.retrofit2:adapter-rxjava2:(version)'
Retrofit
在构建实例时添加调用适配器工厂:
private val INSTANCE =
Retrofit.Builder()
.baseUrl("http://www.janbarar.ir/App/")
.addCallAdapterFactory(RxJava2CallAdapterFactory.create()) // add this
.addConverterFactory(GsonConverterFactory.create())
.build()
.create(IRetrofitMethods::class.java)
然后让你的服务直接返回一个 Observable:
@GET("GetCategories")
fun getCategories(): Observable<List<Category>>
如果ApiService
需要在应用程序的其余部分得到响应之前进行一些处理,您可以使用 RxJava 运算符,如map
.
看看您的代码为什么不起作用以及如何修复它,这将是说明性的。当您调用api.getCategories(someCallback)
时,您的回调方法之一将在将来的某个时间点被调用。同时,该model.getCategories()
方法将立即返回。
当您订阅返回的Observable
时,它会发出result
变量,该变量当前是一个空列表。 result
最终会在其中包含一些数据,但您的代码根本不会被告知这一点。
您真正想要做的是在可用时发出类别列表。Observable
从回调 API获取的标准方法是Observable.create
:
fun getCategories(): Observable<ArrayList<Category>> {
return Observable.create { emitter ->
api.getCategories(object : IDataTransfer<List<Category>> {
override fun onSuccess(data: List<Category>) {
emitter.onNext(data)
emitter.onComplete()
}
override fun onError(throwable: Throwable) {
emitter.onError(throwable)
}
})
}
}
当然,RxJava2CallAdapterFactory
如果可能的话最好只使用,因为这项工作已经在那里完成了。
推荐阅读
- bazel - 如何在 Bazel 中启用 doclint
- macos - macOS Big Sur 中的分段错误后未生成核心转储文件
- google-cloud-platform - 如何避免找不到文件(WinError 3)?
- curve - 如何在 Maxima CAS 中绘制旋转椭圆?
- pandas - 获取索引前 n 天的行子集
- pine-script - 如何在查看 Heikin Ashi 图表时获取 OHLC 蜡烛值?
- reactjs - Jest/React/Mobx:TypeError mobxReact.observer 不是函数
- shell - Ansible 显示项目在循环中未定义
- reactjs - 使用 React Native Paper 为 iOS 和 Android 的不同屏幕正确缩放字体需要考虑哪些不同的参数?
- python - ConvergenceError:由于矩阵求逆问题导致收敛停止