Fixed history was not showing on the HistoryScreen.

buildSrc/src/main/kotlin/Libs.kt

@@ -26,6 +26,12 @@ object Libs {
   const val kotlinx_coroutines_test: String = "org.jetbrains.kotlinx:kotlinx-coroutines-test:" +
     Versions.org_jetbrains_kotlinx_kotlinx_coroutines
 
+  /**
+   * https://github.com/Kotlin/kotlinx.coroutines
+   */
+  const val kotlinx_coroutines_rx2: String = "org.jetbrains.kotlinx:kotlinx-coroutines-rx2:" +
+    Versions.org_jetbrains_kotlinx_kotlinx_coroutines
+
   /**
    * https://developer.android.com/testing
    */

buildSrc/src/main/kotlin/plugin/AllProjectConfigurer.kt

@@ -204,6 +204,7 @@ class AllProjectConfigurer {
       implementation(Libs.fetch)
       implementation(Libs.rxandroid)
       implementation(Libs.rxjava)
+      implementation(Libs.kotlinx_coroutines_rx2)
       implementation(Libs.preference_ktx)
       implementation(Libs.material_show_case_view)
       implementation(Libs.roomKtx)

core/src/main/java/org/kiwix/kiwixmobile/core/page/viewmodel/PageViewModel.kt

@@ -20,12 +20,11 @@ package org.kiwix.kiwixmobile.core.page.viewmodel
 
 import androidx.lifecycle.MutableLiveData
 import androidx.lifecycle.ViewModel
-import androidx.lifecycle.viewModelScope
 import io.reactivex.disposables.CompositeDisposable
 import io.reactivex.disposables.Disposable
 import io.reactivex.processors.PublishProcessor
 import io.reactivex.schedulers.Schedulers
-import kotlinx.coroutines.launch
+import kotlinx.coroutines.rx2.asFlowable
 import org.kiwix.kiwixmobile.core.base.SideEffect
 import org.kiwix.kiwixmobile.core.dao.BasePageDao
 import org.kiwix.kiwixmobile.core.dao.PageDao
@@ -84,13 +83,11 @@ abstract class PageViewModel<T : Page, S : PageState<T>>(
       }
 
       is PageRoomDao -> {
-        viewModelScope.launch {
+        compositeDisposable.addAll(
-          try {
+          viewStateReducer(),
-            // basePageDao.pages().collect(::UpdatePages)
+          basePageDao.pages().asFlowable().subscribeOn(Schedulers.io())
-          } catch (ignore: Exception) {
+            .subscribe({ actions.offer(UpdatePages(it)) }, Throwable::printStackTrace)
-            ignore.printStackTrace()
+        )
-          }
-        }
       }
     }
   }