Use coroutines in TagPickerViewModel

app/src/main/java/org/tasks/data/TagDataDaoBlocking.kt

@@ -9,15 +9,7 @@ class TagDataDaoBlocking @Inject constructor(private val dao: TagDataDao) {
         return dao.subscribeToTags()
     }
 
-    fun searchTags(query: String): List<TagData> = runBlocking {
-        dao.searchTags(query)
-    }
-
     fun tagDataOrderedByName(): List<TagData> = runBlocking {
         dao.tagDataOrderedByName()
     }
-
-    fun createNew(tag: TagData) = runBlocking {
-        dao.createNew(tag)
-    }
 }

app/src/main/java/org/tasks/tags/TagPickerViewModel.kt

@@ -1,23 +1,20 @@
 package org.tasks.tags
 
 import androidx.hilt.lifecycle.ViewModelInject
-import androidx.lifecycle.LifecycleOwner
+import androidx.lifecycle.*
-import androidx.lifecycle.MutableLiveData
 import androidx.lifecycle.Observer
-import androidx.lifecycle.ViewModel
+import kotlinx.coroutines.launch
-import io.reactivex.Single
-import io.reactivex.android.schedulers.AndroidSchedulers
-import io.reactivex.disposables.CompositeDisposable
-import io.reactivex.schedulers.Schedulers
 import org.tasks.Strings.isNullOrEmpty
 import org.tasks.data.TagData
-import org.tasks.data.TagDataDaoBlocking
+import org.tasks.data.TagDataDao
 import org.tasks.tags.CheckBoxTriStates.State
 import java.util.*
 
-class TagPickerViewModel @ViewModelInject constructor(private val tagDataDao: TagDataDaoBlocking) : ViewModel() {
+class TagPickerViewModel @ViewModelInject constructor(
+        private val tagDataDao: TagDataDao
+) : ViewModel() {
+
     private val tags = MutableLiveData<List<TagData>>()
-    private val disposables = CompositeDisposable()
     private val selected: MutableSet<TagData> = HashSet()
     private val partiallySelected: MutableSet<TagData> = HashSet()
     var text: String? = null
@@ -37,15 +34,14 @@ class TagPickerViewModel @ViewModelInject constructor(private val tagDataDao: Ta
 
     fun getPartiallySelected() = ArrayList(partiallySelected)
 
-    fun search(text: String) {
+    fun search(newText: String) {
-        if (!text.equals(this.text, ignoreCase = true)) {
+        if (!newText.equals(text, ignoreCase = true)) {
-            disposables.add(
+            viewModelScope.launch {
-                    Single.fromCallable { tagDataDao.searchTags(text) }
+                val results = tagDataDao.searchTags(newText)
-                            .subscribeOn(Schedulers.io())
+                onUpdate(results.toMutableList())
-                            .observeOn(AndroidSchedulers.mainThread())
+            }
-                            .subscribe { results: List<TagData> -> onUpdate(results.toMutableList()) })
         }
-        this.text = text
+        text = newText
     }
 
     private fun onUpdate(results: MutableList<TagData>) {
@@ -55,11 +51,6 @@ class TagPickerViewModel @ViewModelInject constructor(private val tagDataDao: Ta
         tags.value = results
     }
 
-    override fun onCleared() {
-        super.onCleared()
-        disposables.dispose()
-    }
-
     fun getState(tagData: TagData): State {
         if (partiallySelected.contains(tagData)) {
             return State.PARTIALLY_CHECKED
@@ -71,8 +62,10 @@ class TagPickerViewModel @ViewModelInject constructor(private val tagDataDao: Ta
         var tagData = tagData
         if (tagData.id == null) {
             tagData = TagData(tagData.name)
+            viewModelScope.launch {
                 tagDataDao.createNew(tagData)
             }
+        }
         partiallySelected.remove(tagData)
         return if (checked) {
             selected.add(tagData)