android - 在 Kotlin Lambda 中调用 RxJava Single

Question

我正在尝试修补新的 Room库将其与 RxJava 配对。

我找到了一种方法，可以使用 Single 像这样在 Activity 内部的后台线程上插入项目:

Single.fromCallable { AppDatabase.getInMemoryDatabase(this).taskDao().insertAll(task) }
                    .subscribeOn(Schedulers.newThread())
                    .subscribe()

现在，我有一个带有任务的 RecyclerView，它有一个复选框，您可以使用它来将项目标记为完成或未完成。我想要做的是在每次选中/取消选中时更新该项目。我将粘贴整个 ViewHolder 以完成，但要特别注意 bindTask() 中的 lambda:

inner class TaskViewHolder(view: View?) : RecyclerView.ViewHolder(view) {
        val descriptionTextView = view?.findViewById(R.id.task_description) as? TextView
        val completedCheckBox = view?.findViewById(R.id.task_completed) as? CheckBox

        fun bindTask(task: Task) {
            descriptionTextView?.text = task.description
            completedCheckBox?.isChecked = task.completed

            completedCheckBox?.setOnCheckedChangeListener { _, isChecked ->
                tasks[adapterPosition].completed = isChecked

                Single.fromCallable { itemView.context.taskDao().update(tasks[adapterPosition]) }
                        .subscribeOn(Schedulers.newThread())
                        .subscribe()
            }
        }
    }

这适用于我选中的第一个项目，但之后我无法单击任何其他复选框。我以为 Single 会 self 毁灭，但也许我不能在 lambda 中这样做？我需要以某种方式将 Single 拉到外面吗？

Answer 1

我会使用 Observable.create 创建 Observable，使用 lambda 保存发射器，然后使用 setOnCheckedChangeListener 传递下一个项目emitter.onNext()

class TaskViewHolder(view: View) : RecyclerView.ViewHolder(view)
{
    private lateinit var emitter: ObservableEmitter<Task>
    private val disposable: Disposable = Observable.create(ObservableOnSubscribe<Task> { e -> emitter = e })
            .subscribeOn(Schedulers.newThread())
            .observeOn(Schedulers.newThread())
            .subscribe({ itemView.context.taskDao().update(it) })
    val descriptionTextView = view?.findViewById(R.id.task_description) as? TextView
    val completedCheckBox = view?.findViewById(R.id.task_completed) as? CheckBox

    fun bindTask(task: Task) {
        descriptionTextView?.text = task.description
        completedCheckBox?.isChecked = task.completed

        completedCheckBox?.setOnCheckedChangeListener { _, isChecked ->
            tasks[adapterPosition].completed = isChecked
            emitter.onNext(tasks[adapterPosition])
        }
    }
}