|
@@ -66,6 +66,7 @@ class DownloadQueue(
|
|
val pageStatusSubject = PublishSubject.create<Int>()
|
|
val pageStatusSubject = PublishSubject.create<Int>()
|
|
setPagesSubject(download.pages, pageStatusSubject)
|
|
setPagesSubject(download.pages, pageStatusSubject)
|
|
return@flatMap pageStatusSubject
|
|
return@flatMap pageStatusSubject
|
|
|
|
+ .onBackpressureBuffer()
|
|
.filter { it == Page.READY }
|
|
.filter { it == Page.READY }
|
|
.map { download }
|
|
.map { download }
|
|
|
|
|