Fix reader bug with new suspend getFlatMetadata
This commit is contained in:
parent
5d600166ea
commit
9603186927
@ -247,15 +247,12 @@ class ReaderPresenter(
|
|||||||
.first()
|
.first()
|
||||||
.observeOn(AndroidSchedulers.mainThread())
|
.observeOn(AndroidSchedulers.mainThread())
|
||||||
// SY -->
|
// SY -->
|
||||||
.flatMap { manga ->
|
.map { manga ->
|
||||||
val source = sourceManager.get(manga.source)?.getMainSource()
|
val source = sourceManager.get(manga.source)?.getMainSource()
|
||||||
if (manga.initialized && source is MetadataSource<*, *>) {
|
if (manga.initialized && source is MetadataSource<*, *>) {
|
||||||
db.getFlatMetadataForManga(mangaId).asRxSingle().map {
|
val flatMeta = db.getFlatMetadataForManga(mangaId).executeAsBlocking()
|
||||||
manga to it?.raise(source.metaClass)
|
manga to flatMeta?.raise(source.metaClass)
|
||||||
}.toObservable()
|
} else manga to null
|
||||||
} else {
|
|
||||||
Observable.just(manga to null)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
.doOnNext { init(it.first, initialChapterId, it.second) }
|
.doOnNext { init(it.first, initialChapterId, it.second) }
|
||||||
// SY <--
|
// SY <--
|
||||||
|
Loading…
x
Reference in New Issue
Block a user