Castopod
/
AntennaPod
mirror of https://github.com/AntennaPod/AntennaPod.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixed NetworkOnMainThreadException

This commit is contained in:
ByteHamster 2019-04-16 22:50:25 +02:00
parent 99c5e9dc39
commit 1fe33fb351
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
core/src/main/java/de/danoeh/antennapod/core/service/playback/PlaybackServiceTaskManager.java
View File

@ -19,6 +19,9 @@ import de.danoeh.antennapod.core.feed.FeedItem;
import de.danoeh.antennapod.core.storage.DBReader; import de.danoeh.antennapod.core.storage.DBReader;
import de.danoeh.antennapod.core.util.playback.Playable; import de.danoeh.antennapod.core.util.playback.Playable;
import de.greenrobot.event.EventBus; import de.greenrobot.event.EventBus;
import io.reactivex.Completable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;
/** /**
@ -262,18 +265,15 @@ public class PlaybackServiceTaskManager {
cancelChapterLoader(); cancelChapterLoader();
} }
Runnable chapterLoader = () -> { if (media.getChapters() == null) {
Log.d(TAG, "Chapter loader started"); Completable.create(emitter -> {
if (media.getChapters() == null) { media.loadChapterMarks();
media.loadChapterMarks(); emitter.onComplete();
if (!Thread.currentThread().isInterrupted() && media.getChapters() != null) { })
callback.onChapterLoaded(media); .subscribeOn(Schedulers.io())
} .observeOn(AndroidSchedulers.mainThread())
} .subscribe(() -> callback.onChapterLoaded(media));
Log.d(TAG, "Chapter loader stopped"); }
};
chapterLoader = useMainThreadIfNecessary(chapterLoader);
chapterLoaderFuture = schedExecutor.submit(chapterLoader);
} }