在kotlin中使用Mvvm和Retrofit和Rxjava实时数据的问题
我是kotlin的新手，我正在尝试在MVVM体系结构中使用Rxjava和实时数据的改进。我配置修改，并在ViewModel中使用可观察和订阅来使可观察的变量用于活动绑定布局。我的视图中有一个按钮，当我单击它时，request方法将开始并订阅它自己的数据的日志。但是我的变量在一开始和几秒钟后获得null，当更新完成它的任务时，我的变量会获得数据，但是日志值不会更新。
这是我的改装初始化类
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())
})
}回答 1
Stack Overflow用户
发布于 2020-05-25 15:54:39
正如ExpensiveBelly在注释中提到的，Retrofit为RxJava提供了一个调用适配器，因此您可以让API直接返回Observable<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)然后让您的服务返回一个可以直接观察到的结果：
@GET("GetCategories")
fun getCategories(): Observable<List<Category>>如果ApiService需要在应用程序的其余部分得到响应之前进行一些处理，您可以使用RxJava操作符，比如map。
看看为什么您的代码不能工作，以及如何修复它，这将是说明性的。当您调用api.getCategories(someCallback)时，您的回调方法之一将在将来的某个时候被调用。同时，model.getCategories()方法将立即返回。
当您订阅返回的Observable时，它会发出result变量，该变量当前是一个空列表。result最终将在其中包含一些数据，但是您的代码将完全不被告知这一点。
您真正想要做的是在类别列表可用时发出它。从回调API获取Observable的标准方法是使用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，因为这项工作已经在那里完成了。
https://stackoverflow.com/questions/61985780
复制相似问题
腾讯云开发者
