all: smoother extension lifecycle flowing (fixes #13074) (#13076)

Okuro3499 · dogi · web-flow · commit a6808a7460ec · 2026-04-21T13:52:42.000-04:00
Co-authored-by: dogi &lt;dogi@users.noreply.github.com&gt;
diff --git a/app/build.gradle b/app/build.gradle
@@ -12,8 +12,8 @@ android {
         applicationId "org.ole.planet.myplanet"
         minSdk = 26
         targetSdk = 36
-        versionCode = 5357
-        versionName = "0.53.57"
+        versionCode = 5358
+        versionName = "0.53.58"
         ndkVersion = '26.3.11579264'
         vectorDrawables.useSupportLibrary = true
     }
diff --git a/app/src/main/java/org/ole/planet/myplanet/repository/RealmRepository.kt b/app/src/main/java/org/ole/planet/myplanet/repository/RealmRepository.kt
@@ -52,7 +52,7 @@ open class RealmRepository(
             realm.where(clazz).apply(builder).count()
         }
 
-    protected suspend fun <T : RealmObject> queryListFlow(
+    protected fun <T : RealmObject> queryListFlow(
         clazz: Class<T>,
         builder: RealmQuery<T>.() -> Unit = {},
     ): Flow<List<T>> = callbackFlow<RealmResults<T>> {
diff --git a/app/src/main/java/org/ole/planet/myplanet/repository/ResourcesRepository.kt b/app/src/main/java/org/ole/planet/myplanet/repository/ResourcesRepository.kt
@@ -40,8 +40,8 @@ interface ResourcesRepository {
     suspend fun getMyLibrary(userId: String?): List<RealmMyLibrary>
     suspend fun getStepResources(stepId: String?, resourceOffline: Boolean): List<RealmMyLibrary>
     suspend fun getAllStepResources(stepId: String?): List<RealmMyLibrary>
-    suspend fun getRecentResources(userId: String): Flow<List<RealmMyLibrary>>
-    suspend fun getPendingDownloads(userId: String): Flow<List<RealmMyLibrary>>
+    fun getRecentResources(userId: String): Flow<List<RealmMyLibrary>>
+    fun getPendingDownloads(userId: String): Flow<List<RealmMyLibrary>>
     suspend fun getPrivateImagesCreatedAfter(timestamp: Long): List<RealmMyLibrary>
     suspend fun countLibrariesNeedingUpdate(userId: String?): Int
     suspend fun resourceTitleExists(title: String): Boolean
diff --git a/app/src/main/java/org/ole/planet/myplanet/repository/ResourcesRepositoryImpl.kt b/app/src/main/java/org/ole/planet/myplanet/repository/ResourcesRepositoryImpl.kt
@@ -303,15 +303,15 @@ class ResourcesRepositoryImpl @Inject constructor(
         return imageList.mapNotNull { it.resourceRemoteAddress }
     }
 
-    override suspend fun getRecentResources(userId: String): Flow<List<RealmMyLibrary>> {
+    override fun getRecentResources(userId: String): Flow<List<RealmMyLibrary>> {
         return queryListFlow(RealmMyLibrary::class.java) {
             equalTo("userId", userId)
                 .sort("createdDate", Sort.DESCENDING)
                 .limit(10)
         }
     }
 
-    override suspend fun getPendingDownloads(userId: String): Flow<List<RealmMyLibrary>> {
+    override fun getPendingDownloads(userId: String): Flow<List<RealmMyLibrary>> {
         return queryListFlow(RealmMyLibrary::class.java) {
             equalTo("userId", userId)
                 .equalTo("resourceOffline", false)
diff --git a/app/src/main/java/org/ole/planet/myplanet/repository/SubmissionsRepository.kt b/app/src/main/java/org/ole/planet/myplanet/repository/SubmissionsRepository.kt
@@ -8,7 +8,7 @@ import org.ole.planet.myplanet.model.SubmissionDetail
 import org.ole.planet.myplanet.model.SubmissionItem
 
 interface SubmissionsRepository {
-    suspend fun getPendingSurveysFlow(userId: String?): Flow<List<RealmSubmission>>
+    fun getPendingSurveysFlow(userId: String?): Flow<List<RealmSubmission>>
     suspend fun getSubmissionsFlow(userId: String): Flow<List<RealmSubmission>>
     suspend fun getPendingSurveys(userId: String?): List<RealmSubmission>
     suspend fun getUniquePendingSurveys(userId: String?): List<RealmSubmission>
diff --git a/app/src/main/java/org/ole/planet/myplanet/repository/SubmissionsRepositoryImpl.kt b/app/src/main/java/org/ole/planet/myplanet/repository/SubmissionsRepositoryImpl.kt
@@ -39,7 +39,7 @@ class SubmissionsRepositoryImpl @Inject internal constructor(
         return parentId?.substringBefore("@")
     }
 
-    override suspend fun getPendingSurveysFlow(userId: String?): Flow<List<RealmSubmission>> {
+    override fun getPendingSurveysFlow(userId: String?): Flow<List<RealmSubmission>> {
         return queryListFlow(RealmSubmission::class.java) {
             equalTo("userId", userId)
                 .equalTo("type", "survey")
@@ -719,10 +719,10 @@ private suspend fun getExamsByIds(examIds: List<String>): List<RealmStepExam> {
 
             var sub = mRealm.where(RealmSubmission::class.java).equalTo("_id", id).findFirst()
             val isNewSubmission = sub == null
-            val hadLocalChanges = !isNewSubmission && sub?.isUpdated == true
+            val hadLocalChanges = !isNewSubmission && sub.isUpdated
             val serverStatus = org.ole.planet.myplanet.utils.JsonUtils.getString("status", submission)
             val isStatusDowngrade = !isNewSubmission && serverStatus == "pending" &&
-                (sub?.status == "complete" || sub?.status == "requires grading")
+                (sub.status == "complete" || sub.status == "requires grading")
             val skipOverwrite = hadLocalChanges || isStatusDowngrade
 
             if (sub == null) {
diff --git a/app/src/main/java/org/ole/planet/myplanet/repository/TeamsRepository.kt b/app/src/main/java/org/ole/planet/myplanet/repository/TeamsRepository.kt
@@ -63,7 +63,7 @@ interface TeamsRepository {
     suspend fun getJoinRequestTeamId(requestId: String): String?
     suspend fun getTaskNotifications(userId: String?): List<Triple<String, String, String>>
     suspend fun getJoinRequestNotifications(userId: String?): List<JoinRequestNotification>
-    suspend fun getTasksFlow(userId: String?): Flow<List<RealmTeamTask>>
+    fun getTasksFlow(userId: String?): Flow<List<RealmTeamTask>>
     suspend fun getTasks(userId: String?): List<RealmTeamTask>
     suspend fun isMember(userId: String?, teamId: String): Boolean
     suspend fun isTeamLeader(teamId: String, userId: String?): Boolean
diff --git a/app/src/main/java/org/ole/planet/myplanet/repository/TeamsRepositoryImpl.kt b/app/src/main/java/org/ole/planet/myplanet/repository/TeamsRepositoryImpl.kt
@@ -55,7 +55,7 @@ class TeamsRepositoryImpl @Inject constructor(
     private val dispatcherProvider: DispatcherProvider,
     private val userRepository: UserRepository,
 ) : RealmRepository(databaseService, realmDispatcher), TeamsRepository {
-    override suspend fun getTasksFlow(userId: String?): Flow<List<RealmTeamTask>> {
+    override fun getTasksFlow(userId: String?): Flow<List<RealmTeamTask>> {
         return queryListFlow(RealmTeamTask::class.java) {
             notEqualTo("status", "archived")
                 .equalTo("completed", false)
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/courses/CourseDetailFragment.kt b/app/src/main/java/org/ole/planet/myplanet/ui/courses/CourseDetailFragment.kt
@@ -6,12 +6,9 @@ import android.view.View
 import android.view.ViewGroup
 import android.widget.TextView
 import androidx.fragment.app.viewModels
-import androidx.lifecycle.Lifecycle
-import androidx.lifecycle.lifecycleScope
-import androidx.lifecycle.repeatOnLifecycle
 import androidx.recyclerview.widget.LinearLayoutManager
 import dagger.hilt.android.AndroidEntryPoint
-import kotlinx.coroutines.launch
+import org.ole.planet.myplanet.utils.collectWhenStarted
 import org.ole.planet.myplanet.MainApplication
 import org.ole.planet.myplanet.R
 import org.ole.planet.myplanet.base.BaseContainerFragment
@@ -48,21 +45,17 @@ class CourseDetailFragment : BaseContainerFragment(), OnRatingChangeListener {
             viewModel.loadCourseDetail(it)
         }
 
-        viewLifecycleOwner.lifecycleScope.launch {
-            viewLifecycleOwner.repeatOnLifecycle(Lifecycle.State.STARTED) {
-                viewModel.uiState.collect { state ->
-                    when (state) {
-                        is CourseDetailUiState.Loading -> {
-                            // Show loading indicator if needed
-                        }
-                        is CourseDetailUiState.Success -> {
-                            bindCourseData(state)
-                        }
-                        is CourseDetailUiState.Error -> {
-                            context?.let { ctx ->
-                                android.widget.Toast.makeText(ctx, state.message, android.widget.Toast.LENGTH_LONG).show()
-                            }
-                        }
+        collectWhenStarted(viewModel.uiState) { state ->
+            when (state) {
+                is CourseDetailUiState.Loading -> {
+                    // Show loading indicator if needed
+                }
+                is CourseDetailUiState.Success -> {
+                    bindCourseData(state)
+                }
+                is CourseDetailUiState.Error -> {
+                    context?.let { ctx ->
+                        android.widget.Toast.makeText(ctx, state.message, android.widget.Toast.LENGTH_LONG).show()
                     }
                 }
             }
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/courses/CourseProgressActivity.kt b/app/src/main/java/org/ole/planet/myplanet/ui/courses/CourseProgressActivity.kt
@@ -2,12 +2,9 @@ package org.ole.planet.myplanet.ui.courses
 
 import android.os.Bundle
 import androidx.activity.viewModels
-import androidx.lifecycle.Lifecycle
-import androidx.lifecycle.lifecycleScope
-import androidx.lifecycle.repeatOnLifecycle
 import androidx.recyclerview.widget.GridLayoutManager
 import dagger.hilt.android.AndroidEntryPoint
-import kotlinx.coroutines.launch
+import org.ole.planet.myplanet.utils.collectWhenStarted
 import org.ole.planet.myplanet.R
 import org.ole.planet.myplanet.base.BaseActivity
 import org.ole.planet.myplanet.databinding.ActivityCourseProgressBinding
@@ -30,13 +27,9 @@ class CourseProgressActivity : BaseActivity() {
 
         binding.rvProgress.layoutManager = GridLayoutManager(this, 4)
 
-        lifecycleScope.launch {
-            repeatOnLifecycle(Lifecycle.State.STARTED) {
-                viewModel.courseProgress.collect { data ->
-                    if (data != null) {
-                        updateUI(data)
-                    }
-                }
+        collectWhenStarted(viewModel.courseProgress) { data ->
+            if (data != null) {
+                updateUI(data)
             }
         }
         viewModel.loadProgress(courseId)
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/courses/CoursesProgressFragment.kt b/app/src/main/java/org/ole/planet/myplanet/ui/courses/CoursesProgressFragment.kt
@@ -15,6 +15,7 @@ import com.google.gson.JsonObject
 import dagger.hilt.android.AndroidEntryPoint
 import kotlinx.coroutines.launch
 import org.ole.planet.myplanet.databinding.FragmentCoursesProgressBinding
+import org.ole.planet.myplanet.utils.collectWhenStarted
 
 @AndroidEntryPoint
 class CoursesProgressFragment : Fragment() {
@@ -38,14 +39,10 @@ class CoursesProgressFragment : Fragment() {
     }
 
     private fun observeCourseData() {
-        viewLifecycleOwner.lifecycleScope.launch {
-            repeatOnLifecycle(Lifecycle.State.STARTED) {
-                progressViewModel.courseData.collect { courseData ->
-                    courseData?.let { jsonArray ->
-                        val list = jsonArray.map { it.asJsonObject }
-                        progressAdapter.submitList(list)
-                    }
-                }
+        collectWhenStarted(progressViewModel.courseData) { courseData ->
+            courseData?.let { jsonArray ->
+                val list = jsonArray.map { it.asJsonObject }
+                progressAdapter.submitList(list)
             }
         }
     }
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/dashboard/DashboardActivity.kt b/app/src/main/java/org/ole/planet/myplanet/ui/dashboard/DashboardActivity.kt
@@ -83,6 +83,7 @@ import org.ole.planet.myplanet.utils.EdgeToEdgeUtils
 import org.ole.planet.myplanet.utils.KeyboardUtils.setupUI
 import org.ole.planet.myplanet.utils.LocaleUtils
 import org.ole.planet.myplanet.utils.NotificationUtils
+import org.ole.planet.myplanet.utils.collectWhenStarted
 import org.ole.planet.myplanet.utils.Utilities.toast
 
 @AndroidEntryPoint  
@@ -549,12 +550,8 @@ class DashboardActivity : DashboardElementActivity(), OnHomeItemClickListener, N
     }
 
     private fun setupDashboardDataObserver() {
-        lifecycleScope.launch {
-            repeatOnLifecycle(Lifecycle.State.STARTED) {
-                dashboardViewModel.dashboardDataFlow(user?.id).collect {
-                    onRealmDataChange()
-                }
-            }
+        collectWhenStarted(dashboardViewModel.dashboardDataFlow(user?.id)) {
+            onRealmDataChange()
         }
     }
 
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/dashboard/DashboardViewModel.kt b/app/src/main/java/org/ole/planet/myplanet/ui/dashboard/DashboardViewModel.kt
@@ -201,7 +201,7 @@ class DashboardViewModel @Inject constructor(
         }
     }
 
-    suspend fun dashboardDataFlow(userId: String?): Flow<Unit> {
+    fun dashboardDataFlow(userId: String?): Flow<Unit> {
         return merge(
             resourcesRepository.getRecentResources(userId ?: "").map {},
             resourcesRepository.getPendingDownloads(userId ?: "").map {},
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/feedback/FeedbackListFragment.kt b/app/src/main/java/org/ole/planet/myplanet/ui/feedback/FeedbackListFragment.kt
@@ -29,6 +29,7 @@ import org.ole.planet.myplanet.services.sync.RealtimeSyncManager
 import org.ole.planet.myplanet.services.sync.ServerUrlMapper
 import org.ole.planet.myplanet.services.sync.SyncManager
 import org.ole.planet.myplanet.utils.DialogUtils
+import org.ole.planet.myplanet.utils.collectWhenStarted
 import org.ole.planet.myplanet.utils.DispatcherProvider
 
 @AndroidEntryPoint
@@ -168,12 +169,8 @@ class FeedbackListFragment : Fragment(), OnFeedbackSubmittedListener {
     }
 
     private fun observeFeedbackList() {
-        viewLifecycleOwner.lifecycleScope.launch {
-            repeatOnLifecycle(Lifecycle.State.STARTED) {
-                viewModel.feedbackList.collect { feedbackList ->
-                    updatedFeedbackList(feedbackList)
-                }
-            }
+        collectWhenStarted(viewModel.feedbackList) { feedbackList ->
+            updatedFeedbackList(feedbackList)
         }
     }
 
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/personals/PersonalsFragment.kt b/app/src/main/java/org/ole/planet/myplanet/ui/personals/PersonalsFragment.kt
@@ -23,6 +23,7 @@ import org.ole.planet.myplanet.model.RealmMyPersonal
 import org.ole.planet.myplanet.services.UploadManager
 import org.ole.planet.myplanet.ui.resources.AddResourceFragment
 import org.ole.planet.myplanet.utils.DialogUtils
+import org.ole.planet.myplanet.utils.collectLatestWhenStarted
 import org.ole.planet.myplanet.utils.Utilities
 
 @AndroidEntryPoint
@@ -61,13 +62,9 @@ class PersonalsFragment : Fragment(), OnPersonalSelectedListener {
         personalAdapter = PersonalsAdapter(requireActivity())
         personalAdapter?.setListener(this)
         binding.rvMypersonal.adapter = personalAdapter
-        viewLifecycleOwner.lifecycleScope.launch {
-            repeatOnLifecycle(Lifecycle.State.STARTED) {
-                viewModel.personals.collectLatest { realmMyPersonals ->
-                    personalAdapter?.submitList(realmMyPersonals)
-                    showNodata()
-                }
-            }
+        collectLatestWhenStarted(viewModel.personals) { realmMyPersonals ->
+            personalAdapter?.submitList(realmMyPersonals)
+            showNodata()
         }
         showNodata()
     }
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/resources/ResourcesFragment.kt b/app/src/main/java/org/ole/planet/myplanet/ui/resources/ResourcesFragment.kt
@@ -46,6 +46,7 @@ import org.ole.planet.myplanet.utils.DialogUtils
 import org.ole.planet.myplanet.utils.DialogUtils.guestDialog
 import org.ole.planet.myplanet.utils.DispatcherProvider
 import org.ole.planet.myplanet.utils.KeyboardUtils.setupUI
+import org.ole.planet.myplanet.utils.collectWhenStarted
 import org.ole.planet.myplanet.utils.Utilities
 
 @AndroidEntryPoint
@@ -86,45 +87,6 @@ class ResourcesFragment : BaseRecyclerFragment<RealmMyLibrary?>(), OnLibraryItem
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
         viewModel.startResourcesSync()
-
-        lifecycleScope.launch {
-            repeatOnLifecycle(Lifecycle.State.STARTED) {
-                viewModel.syncState.collect { state ->
-                    when (state) {
-                        is org.ole.planet.myplanet.model.SyncState.Syncing -> {
-                            if (isAdded && !requireActivity().isFinishing && view != null) {
-                                customProgressDialog = DialogUtils.CustomProgressDialog(requireContext())
-                                customProgressDialog?.setText(getString(R.string.syncing_resources))
-                                customProgressDialog?.show()
-                            }
-                        }
-                        is org.ole.planet.myplanet.model.SyncState.Success -> {
-                            if (isAdded && view != null) {
-                                customProgressDialog?.dismiss()
-                                customProgressDialog = null
-                                refreshResourcesData()
-                                viewModel.resetSyncState()
-                            }
-                        }
-                        is org.ole.planet.myplanet.model.SyncState.Failed -> {
-                            if (isAdded && view != null) {
-                                customProgressDialog?.dismiss()
-                                customProgressDialog = null
-
-                                Snackbar.make(requireView(), "Sync failed: ${state.message ?: "Unknown error"}", Snackbar.LENGTH_LONG
-                                ).setAction("Retry") {
-                                    viewModel.startResourcesSync()
-                                }.show()
-                                viewModel.resetSyncState()
-                            }
-                        }
-                        is org.ole.planet.myplanet.model.SyncState.Idle -> {
-                            // Do nothing
-                        }
-                    }
-                }
-            }
-        }
     }
 
     override fun getLayout(): Int {
@@ -234,6 +196,36 @@ class ResourcesFragment : BaseRecyclerFragment<RealmMyLibrary?>(), OnLibraryItem
         initArrays()
         hideButton()
 
+        collectWhenStarted(viewModel.syncState) { state ->
+            when (state) {
+                is org.ole.planet.myplanet.model.SyncState.Syncing -> {
+                    if (!requireActivity().isFinishing) {
+                        customProgressDialog = DialogUtils.CustomProgressDialog(requireContext())
+                        customProgressDialog?.setText(getString(R.string.syncing_resources))
+                        customProgressDialog?.show()
+                    }
+                }
+                is org.ole.planet.myplanet.model.SyncState.Success -> {
+                    customProgressDialog?.dismiss()
+                    customProgressDialog = null
+                    refreshResourcesData()
+                    viewModel.resetSyncState()
+                }
+                is org.ole.planet.myplanet.model.SyncState.Failed -> {
+                    customProgressDialog?.dismiss()
+                    customProgressDialog = null
+                    Snackbar.make(requireView(), "Sync failed: ${state.message ?: "Unknown error"}", Snackbar.LENGTH_LONG
+                    ).setAction("Retry") {
+                        viewModel.startResourcesSync()
+                    }.show()
+                    viewModel.resetSyncState()
+                }
+                is org.ole.planet.myplanet.model.SyncState.Idle -> {
+                    // Do nothing
+                }
+            }
+        }
+
         lifecycleScope.launch {
             userModel = profileDbHandler.getUserModel()
             setupGuestUserRestrictions()
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/submissions/SubmissionListFragment.kt b/app/src/main/java/org/ole/planet/myplanet/ui/submissions/SubmissionListFragment.kt
@@ -19,6 +19,7 @@ import org.ole.planet.myplanet.callback.OnHomeItemClickListener
 import org.ole.planet.myplanet.databinding.FragmentSubmissionListBinding
 import org.ole.planet.myplanet.repository.SubmissionsRepositoryExporter
 import org.ole.planet.myplanet.utils.FileUtils
+import org.ole.planet.myplanet.utils.collectWhenStarted
 
 @AndroidEntryPoint
 class SubmissionListFragment : Fragment() {
@@ -51,13 +52,9 @@ class SubmissionListFragment : Fragment() {
         binding.tvTitle.text = examTitle ?: "Submissions"
         setupRecyclerView()
 
-        viewLifecycleOwner.lifecycleScope.launch {
-            viewLifecycleOwner.repeatOnLifecycle(Lifecycle.State.STARTED) {
-                viewModel.submissions.collect { submissionItems ->
-                    if (_binding != null) {
-                        adapter.submitList(submissionItems)
-                    }
-                }
+        collectWhenStarted(viewModel.submissions) { submissionItems ->
+            if (_binding != null) {
+                adapter.submitList(submissionItems)
             }
         }
 
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/sync/RealtimeSyncMixin.kt b/app/src/main/java/org/ole/planet/myplanet/ui/sync/RealtimeSyncMixin.kt
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/sync/SyncActivity.kt b/app/src/main/java/org/ole/planet/myplanet/ui/sync/SyncActivity.kt
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/teams/PlanFragment.kt b/app/src/main/java/org/ole/planet/myplanet/ui/teams/PlanFragment.kt
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/teams/TeamFragment.kt b/app/src/main/java/org/ole/planet/myplanet/ui/teams/TeamFragment.kt
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/teams/resources/TeamResourcesFragment.kt b/app/src/main/java/org/ole/planet/myplanet/ui/teams/resources/TeamResourcesFragment.kt
diff --git a/app/src/main/java/org/ole/planet/myplanet/ui/user/UserProfileFragment.kt b/app/src/main/java/org/ole/planet/myplanet/ui/user/UserProfileFragment.kt
diff --git a/app/src/main/java/org/ole/planet/myplanet/utils/FlowExtensions.kt b/app/src/main/java/org/ole/planet/myplanet/utils/FlowExtensions.kt

Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ open class RealmRepository(`
`52`	`52`	`realm.where(clazz).apply(builder).count()`
`53`	`53`	`}`
`54`	`54`
`55`		`- protected suspend fun <T : RealmObject> queryListFlow(`
	`55`	`+ protected fun <T : RealmObject> queryListFlow(`
`56`	`56`	`clazz: Class<T>,`
`57`	`57`	`builder: RealmQuery<T>.() -> Unit = {},`
`58`	`58`	`): Flow<List<T>> = callbackFlow<RealmResults<T>> {`
Original file line number	Diff line number	Diff line change
`@@ -303,15 +303,15 @@ class ResourcesRepositoryImpl @Inject constructor(`
`303`	`303`	`return imageList.mapNotNull { it.resourceRemoteAddress }`
`304`	`304`	`}`
`305`	`305`
`306`		`- override suspend fun getRecentResources(userId: String): Flow<List<RealmMyLibrary>> {`
	`306`	`+ override fun getRecentResources(userId: String): Flow<List<RealmMyLibrary>> {`
`307`	`307`	`return queryListFlow(RealmMyLibrary::class.java) {`
`308`	`308`	`equalTo("userId", userId)`
`309`	`309`	`.sort("createdDate", Sort.DESCENDING)`
`310`	`310`	`.limit(10)`
`311`	`311`	`}`
`312`	`312`	`}`
`313`	`313`
`314`		`- override suspend fun getPendingDownloads(userId: String): Flow<List<RealmMyLibrary>> {`
	`314`	`+ override fun getPendingDownloads(userId: String): Flow<List<RealmMyLibrary>> {`
`315`	`315`	`return queryListFlow(RealmMyLibrary::class.java) {`
`316`	`316`	`equalTo("userId", userId)`
`317`	`317`	`.equalTo("resourceOffline", false)`