|
@@ -229,7 +229,6 @@ class CataloguePresenter : BasePresenter<CatalogueFragment>() {
|
|
source.fetchSearchManga(nextMangasPage, query)
|
|
source.fetchSearchManga(nextMangasPage, query)
|
|
|
|
|
|
return observable.subscribeOn(Schedulers.io())
|
|
return observable.subscribeOn(Schedulers.io())
|
|
- .doOnNext { if (it.mangas.isEmpty()) throw Exception("Empty page") }
|
|
|
|
.doOnNext { lastMangasPage = it }
|
|
.doOnNext { lastMangasPage = it }
|
|
.flatMap { Observable.from(it.mangas) }
|
|
.flatMap { Observable.from(it.mangas) }
|
|
.map { networkToLocalManga(it) }
|
|
.map { networkToLocalManga(it) }
|