mirror of
https://github.com/AntennaPod/AntennaPod.git
synced 2026-08-18 11:05:49 +00:00
Merge branch 'master' into develop
This commit is contained in:
@ -65,7 +65,7 @@ public class FyydPodcastSearcher implements PodcastSearcher {
|
||||
}
|
||||
subscriber.onSuccess(searchResults);
|
||||
})
|
||||
.subscribeOn(Schedulers.io())
|
||||
.subscribeOn(Schedulers.computation())
|
||||
.observeOn(AndroidSchedulers.mainThread());
|
||||
}
|
||||
|
||||
|
||||
@ -78,8 +78,8 @@ public class DownloadServiceInterfaceImpl extends DownloadServiceInterface {
|
||||
String tag = WORK_TAG_EPISODE_URL + media.getDownloadUrl();
|
||||
Future<List<WorkInfo>> future = WorkManager.getInstance(context).getWorkInfosByTag(tag);
|
||||
Observable.fromFuture(future)
|
||||
.subscribeOn(Schedulers.io())
|
||||
.observeOn(Schedulers.io())
|
||||
.subscribeOn(Schedulers.computation())
|
||||
.observeOn(Schedulers.computation())
|
||||
.subscribe(
|
||||
workInfos -> {
|
||||
for (WorkInfo info : workInfos) {
|
||||
|
||||
@ -28,7 +28,7 @@ public class LockingAsyncExecutor {
|
||||
} finally {
|
||||
lock.unlock();
|
||||
}
|
||||
}).subscribeOn(Schedulers.io())
|
||||
}).subscribeOn(Schedulers.computation())
|
||||
.subscribe();
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user