如何简单地用 RX / Coroutines 替换 android AsyncTask 并返回一个值？

Question

此方法运行数据库操作（返回生成的 ID）并且必须在后台线程上：

fun insert(note: Note): Long{ return noteDao.insert(note) }

有没有办法使用 RX / Coroutines 来实现它？ （不使用suspend 关键字）

我目前使用 AsyncTask：

override fun insert(note: Note): Long {
    return InsertTask(this, noteDao).execute(note).get()
}

private class InsertTask(noteRepository: NoteRepository, private val noteDao: NoteDao) : AsyncTask<Note, Void, Long>() {

    override fun doInBackground(vararg note: Note): Long {
        return noteDao.insert(note[0])
    }

    override fun onPostExecute(generatedId: Long) {
        getTheId(generatedId)
    }

    private fun getTheId( id: Long): Long {
        return id
    }
}

Answer 1

使用协程，这很容易。但是您需要对 Room 的协程支持。

Gradle 依赖：

implementation "androidx.room:room-ktx:2.1.0"

接下来，将 dao 中的方法标记为挂起。

@Insert
suspend fun insert(note: Note): Long

我不知道你有多少关于协程的信息，但它是这样的：

aCoroutineScope.launch(Dispatchers.IO){
 //to make analogy you are inside the do in backgroun here
  val id = dao.insert(note)
  withContext(Dispatchers.Main){
  //oh well you can call this onPostExecute :) 
  //do whatever you need with that selectId here
  handleIdOnTheMainThread(id)
  }
}

但我坚持不要将它与关于协程的 0 信息一起使用。

关于 RxJava：

Room 也支持 Rx，请参考this link。