Revert "Fix reader bug with new suspend getFlatMetadata"
This reverts commit 96031869271b3c5ed43d3c7d227dcdcd584d9618.
This commit is contained in:
parent
dc6aa11bc7
commit
dbadec2c67
@ -247,12 +247,15 @@ class ReaderPresenter(
|
|||||||
.first()
|
.first()
|
||||||
.observeOn(AndroidSchedulers.mainThread())
|
.observeOn(AndroidSchedulers.mainThread())
|
||||||
// SY -->
|
// SY -->
|
||||||
.map { manga ->
|
.flatMap { 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<*, *>) {
|
||||||
val flatMeta = db.getFlatMetadataForManga(mangaId).executeAsBlocking()
|
db.getFlatMetadataForManga(mangaId).asRxSingle().map {
|
||||||
manga to flatMeta?.raise(source.metaClass)
|
manga to it?.raise(source.metaClass)
|
||||||
} else manga to null
|
}.toObservable()
|
||||||
|
} 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