Мой diffcallback areContentsTheSame(oldItem: ItemModel, newItem: ItemModel)
всегда получает один и тот же контент. Я использую статус для проверки, но каждый раз статус один и тот же. Хотя статус на самом деле меняется. Я намерен отображать прогресс для каждого элемента. Так что я регулярно отправляю текущий прогресс через статус. Используя diffcallback, он должен проверить, что состояние элемента не совпадает, а затем обновить только этот элемент. Но кажется, что newItem и oldItem, которые он получает, совпадают.
У меня есть пользовательская модель ItemModel
data class ItemModel(val id: String, var title: String) {
var clickListener: ClickListener? = null
var status: Status? = null
interface ClickListener{
fun onItemClick(view: View, item: ItemModel)
fun onClick(view: View, item: ItemModel)
}
companion object {
val STATUS_CHANGED = 1
val diffCallback = object : DiffUtil.ItemCallback<ItemModel>() {
override fun areItemsTheSame(oldItem: ItemModel, newItem: ItemModel): Boolean {
// Log.i("DiffUtil", "SameItem? old status: ${oldItem.status}, new Status: ${newItem.status}")
return oldItem.id == newItem.id
}
override fun areContentsTheSame(oldItem: ItemModel, newItem: ItemModel): Boolean {
// Log.i("DiffUtil", "Checking status: new: ${newItem.status}, old ${oldItem.status}")
return oldItem.status == newItem.status
}
override fun getChangePayload(oldItem: ItemModel, newItem: ItemModel): Any? {
Log.i("DiffUtil", "Payload change: ${newItem.status?.state}")
if (oldItem.status != newItem.status) {
return STATUS_CHANGED
}
return null
}
}
}
}
И статус данных класса
data class Status(val max: Int, val progress: Int, val state: State = State.NONE)
Это мой класс ViewModel; Я использую Observable.intervalRange
для генерации разных номеров и изменения статуса одного элемента списка. Но похоже, что diffcallback не работает должным образом.
class FunViewModel : ViewModel() {
private val itemModels: MutableLiveData<List<ItemModel>> = MutableLiveData()
fun items(): LiveData<List<ItemModel>> {
return itemModels
}
private val compositeDisposable = CompositeDisposable()
fun initialize(itemList: List<ItemModel>) {
itemModels.value = itemList
}
private fun updateItem(item: ItemModel, status: Status) {
val currentItems = mutableListOf<ItemModel>()
if (itemModels.value == null) return
currentItems.addAll(itemModels.value!!)
Log.i("UpdateItem", "Current item: ${item.id}")
if (currentItems.isNotEmpty()) {
for ((index, el) in currentItems.withIndex()) {
// Log.i("UpdateItem", "searching: ${el.id}")
if (el.id == item.id) {
val currentItem = currentItems.removeAt(index)
Log.i("UpdateItem", "old status: ${currentItem.status}")
currentItem.status = status
currentItems.add(index, currentItem)
break
}
}
itemModels.value = currentItems
Log.i("UpdateItem", "new status: ${items().value?.get(0)?.status}")
}
}
fun startProgress(item: ItemModel) {
val disposable = getProgress(item.id).map { progress ->
val status = Status(progress.second.toInt(), progress.third.toInt(), State.IN_PROGRESS)
status
}.subscribeOn(Schedulers.single())
.observeOn(AndroidSchedulers.mainThread())
.subscribe({ status ->
updateItem(item, status)
// Log.i("FunViewModel:", "Status: progress: ${status.progress}, State: ${status.state}")
},
{ throwable: Throwable? -> Log.e("FunViewModel", "Unable to process progress!", throwable) },
{
val status = Status(20, 20, State.COMPLETED)
updateItem(item, status)
Log.i("FunViewModel:", "Status: progress: ${status.progress}, State: ${status.state}")
})
compositeDisposable.add(disposable)
}
private fun getProgress(id: String): Observable<Triple<String, Long, Long>> {
return Observable.intervalRange(0, 20, 300, 500, TimeUnit.MILLISECONDS)
.map { num -> Triple<String, Long, Long>(id, 20, num) }
}
override fun onCleared() {
super.onCleared()
if (!compositeDisposable.isDisposed) compositeDisposable.dispose()
}
}