DownloadController: Fix first active download status not updating (#8069)

2022-09-24 22:59:11 +07:00
parent b8c1257645
commit f98b4f4e39
2 changed files with 12 additions and 14 deletions
@@ -75,7 +75,9 @@ class DownloadQueue(
        Observable.from(this).filter { download -> download.status == Download.State.DOWNLOADING }

    @Deprecated("Use getStatusAsFlow instead")
-    fun getStatusObservable(): Observable<Download> = statusSubject.onBackpressureBuffer()
+    fun getStatusObservable(): Observable<Download> = statusSubject
+        .startWith(getActiveDownloads())
+        .onBackpressureBuffer()

    fun getStatusAsFlow(): Flow<Download> = getStatusObservable().asFlow()