|
@@ -60,7 +60,7 @@ public class UpdateMangaSyncService extends Service {
|
|
|
private void updateLastChapterRead(MangaSync mangaSync, int startId) {
|
|
|
MangaSyncService sync = syncManager.getSyncService(mangaSync.sync_id);
|
|
|
|
|
|
- subscriptions.add(Observable.fromCallable(() -> sync.update(mangaSync))
|
|
|
+ subscriptions.add(Observable.defer(() -> sync.update(mangaSync))
|
|
|
.flatMap(response -> db.insertMangaSync(mangaSync).createObservable())
|
|
|
.subscribeOn(Schedulers.io())
|
|
|
.observeOn(AndroidSchedulers.mainThread())
|