diff --git a/app/build.gradle b/app/build.gradle index 5d51b8531..37a19d331 100644 --- a/app/build.gradle +++ b/app/build.gradle @@ -12,8 +12,8 @@ android { // Version code schema: // "1.2.3-beta4" -> 1020304 // "1.2.3" -> 1020395 - versionCode 3110195 - versionName "3.11.1" + versionCode 3110395 + versionName "3.11.3" javaCompileOptions { annotationProcessorOptions { @@ -142,7 +142,10 @@ dependencies { if (project.hasProperty("antennaPodPlayPublisherCredentials")) { apply plugin: 'com.github.triplet.play' play { - track.set('alpha') + track.set('beta') + //noinspection UnnecessaryQualifiedReference + releaseStatus.set(com.github.triplet.gradle.androidpublisher.ReleaseStatus.IN_PROGRESS) + userFraction.set(0.01d) serviceAccountCredentials.set(file(antennaPodPlayPublisherCredentials)) } } diff --git a/app/src/main/java/de/danoeh/antennapod/activity/OpmlImportActivity.java b/app/src/main/java/de/danoeh/antennapod/activity/OpmlImportActivity.java index e4528b49d..a2838d136 100644 --- a/app/src/main/java/de/danoeh/antennapod/activity/OpmlImportActivity.java +++ b/app/src/main/java/de/danoeh/antennapod/activity/OpmlImportActivity.java @@ -103,7 +103,7 @@ public class OpmlImportActivity extends ToolbarActivity { } FeedUpdateManager.getInstance().runOnce(this); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( () -> { @@ -223,7 +223,7 @@ public class OpmlImportActivity extends ToolbarActivity { reader.close(); return result; }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( result -> { diff --git a/app/src/main/java/de/danoeh/antennapod/activity/SelectSubscriptionActivity.java b/app/src/main/java/de/danoeh/antennapod/activity/SelectSubscriptionActivity.java index 749799b23..0df688a8b 100644 --- a/app/src/main/java/de/danoeh/antennapod/activity/SelectSubscriptionActivity.java +++ b/app/src/main/java/de/danoeh/antennapod/activity/SelectSubscriptionActivity.java @@ -125,7 +125,7 @@ public class SelectSubscriptionActivity extends AppCompatActivity { disposable.dispose(); } disposable = Observable.fromCallable(DBReader::getFeedList) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( result -> { diff --git a/app/src/main/java/de/danoeh/antennapod/activity/SplashActivity.java b/app/src/main/java/de/danoeh/antennapod/activity/SplashActivity.java index e71b0cd49..3312f6305 100644 --- a/app/src/main/java/de/danoeh/antennapod/activity/SplashActivity.java +++ b/app/src/main/java/de/danoeh/antennapod/activity/SplashActivity.java @@ -31,7 +31,7 @@ public class SplashActivity extends Activity { PodDBAdapter.getInstance().close(); subscriber.onComplete(); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( () -> { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/episodeslist/EpisodesListFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/episodeslist/EpisodesListFragment.java index b9fcf560f..850ef279e 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/episodeslist/EpisodesListFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/episodeslist/EpisodesListFragment.java @@ -253,7 +253,7 @@ public abstract class EpisodesListFragment extends Fragment } while (nextPage.size() == EPISODES_PER_PAGE); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(() -> listAdapter.endSelectMode(), error -> Log.e(TAG, Log.getStackTraceString(error))); @@ -282,7 +282,7 @@ public abstract class EpisodesListFragment extends Fragment listAdapter.setDummyViews(1); listAdapter.notifyItemInserted(listAdapter.getItemCount() - 1); disposable = Observable.fromCallable(() -> loadMoreData(page)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( data -> { @@ -401,7 +401,7 @@ public abstract class EpisodesListFragment extends Fragment disposable.dispose(); } disposable = Observable.fromCallable(() -> new Pair<>(loadData(), loadTotalItemCount())) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( data -> { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/AddFeedFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/AddFeedFragment.java index 169a3a23e..8a6425e21 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/AddFeedFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/AddFeedFragment.java @@ -194,7 +194,7 @@ public class AddFeedFragment extends Fragment { return; } Observable.fromCallable(() -> addLocalFolder(uri)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( feed -> { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/SearchFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/SearchFragment.java index 443a582bc..db41e6a07 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/SearchFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/SearchFragment.java @@ -415,7 +415,7 @@ public class SearchFragment extends Fragment implements EpisodeItemListAdapter.O adapterFeeds.updateData(Collections.emptyList()); } else { disposableFeeds = Observable.fromCallable(() -> DBReader.searchFeeds(query, state)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(results -> { progressBar.setVisibility(View.GONE); @@ -424,7 +424,7 @@ public class SearchFragment extends Fragment implements EpisodeItemListAdapter.O }, error -> Log.e(TAG, Log.getStackTraceString(error))); } disposableEpisodes = Observable.fromCallable(() -> DBReader.searchFeedItems(feed, query, state)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(results -> { progressBar.setVisibility(View.GONE); diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/chapter/ChaptersFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/chapter/ChaptersFragment.java index fd2a57436..f5af81c17 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/chapter/ChaptersFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/chapter/ChaptersFragment.java @@ -146,7 +146,7 @@ public class ChaptersFragment extends AppCompatDialogFragment { emitter.onComplete(); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(media -> onMediaChanged((Playable) media), error -> Log.e(TAG, Log.getStackTraceString(error))); diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/download/CompletedDownloadsFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/download/CompletedDownloadsFragment.java index db59a2612..0defb1954 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/download/CompletedDownloadsFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/download/CompletedDownloadsFragment.java @@ -193,7 +193,7 @@ public class CompletedDownloadsFragment extends Fragment Observable.fromCallable(() -> DBReader.getEpisodes(0, Integer.MAX_VALUE, new FeedItemFilter(FeedItemFilter.DOWNLOADED, FeedItemFilter.INCLUDE_NOT_SUBSCRIBED, FeedItemFilter.PLAYED), SortOrder.DATE_OLD_NEW)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(items -> new EpisodeMultiSelectActionHandler(getActivity(), R.id.remove_item) .handleAction(items), error -> Log.e(TAG, Log.getStackTraceString(error))); @@ -329,7 +329,7 @@ public class CompletedDownloadsFragment extends Fragment currentDownloads.addAll(downloadedItems); return currentDownloads; }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( result -> { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/download/DownloadLogDetailsDialog.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/download/DownloadLogDetailsDialog.java index 48f8585f0..41a9082d3 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/download/DownloadLogDetailsDialog.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/download/DownloadLogDetailsDialog.java @@ -125,7 +125,7 @@ public class DownloadLogDetailsDialog extends DialogFragment { } emitter.onSuccess(true); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(obj -> updateUi(), error -> Log.e(TAG, Log.getStackTraceString(error))); diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/download/DownloadLogFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/download/DownloadLogFragment.java index e7ea74db4..ba7f3efa6 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/download/DownloadLogFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/download/DownloadLogFragment.java @@ -110,7 +110,7 @@ public class DownloadLogFragment extends BottomSheetDialogFragment disposable.dispose(); } disposable = Observable.fromCallable(DBReader::getDownloadLog) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { if (result != null) { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/drawer/BottomNavigation.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/drawer/BottomNavigation.java index ab95cbd5f..da0bd31d5 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/drawer/BottomNavigation.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/drawer/BottomNavigation.java @@ -74,7 +74,7 @@ public class BottomNavigation { } bottomNavigationBadgeLoader = Observable.fromCallable( () -> DBReader.getTotalEpisodeCount(new FeedItemFilter(FeedItemFilter.NEW))) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { BadgeDrawable badge = bottomNavigationView.getOrCreateBadge(R.id.bottom_navigation_inbox); diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/drawer/NavDrawerFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/drawer/NavDrawerFragment.java index c067c3cea..95f958c63 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/drawer/NavDrawerFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/drawer/NavDrawerFragment.java @@ -431,7 +431,7 @@ public class NavDrawerFragment extends Fragment implements SharedPreferences.OnS reclaimableSpace = EpisodeCleanupAlgorithmFactory.build().getReclaimableItems(); return new Pair<>(data, makeFlatDrawerData(data.tags, data.feedCounters)); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( result -> { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/episode/ItemFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/episode/ItemFragment.java index 0d0dca2e8..762034077 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/episode/ItemFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/episode/ItemFragment.java @@ -404,7 +404,7 @@ public class ItemFragment extends Fragment { viewBinding.progbarLoading.setVisibility(View.VISIBLE); } disposable = Observable.fromCallable(this::loadInBackground) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { viewBinding.progbarLoading.setVisibility(View.GONE); diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/episode/ItemPagerFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/episode/ItemPagerFragment.java index bbfc6d7d9..191e96e9d 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/episode/ItemPagerFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/episode/ItemPagerFragment.java @@ -133,7 +133,7 @@ public class ItemPagerFragment extends Fragment implements MaterialToolbar.OnMen } disposable = Observable.fromCallable(() -> DBReader.getFeedItem(itemId)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { item = result; diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/FeedInfoFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/FeedInfoFragment.java index 7dd87eb26..a0930bcc6 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/FeedInfoFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/FeedInfoFragment.java @@ -145,7 +145,7 @@ public class FeedInfoFragment extends Fragment implements MaterialToolbar.OnMenu emitter.onComplete(); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { feed = result; @@ -353,7 +353,7 @@ public class FeedInfoFragment extends Fragment implements MaterialToolbar.OnMenu feed.setDownloadUrl(Feed.PREFIX_LOCAL_FOLDER + uri.toString()); FeedDatabaseWriter.updateFeed(getContext(), feed, false); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( () -> EventBus.getDefault().post(new MessageEvent(getString(android.R.string.ok))), diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/FeedItemlistFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/FeedItemlistFragment.java index d0496fcbc..26d4f5a0f 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/FeedItemlistFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/FeedItemlistFragment.java @@ -208,7 +208,7 @@ public class FeedItemlistFragment extends Fragment implements AdapterView.OnItem EpisodeMultiSelectActionHandler handler = new EpisodeMultiSelectActionHandler(getActivity(), menuItem.getItemId()); Completable.fromAction(() -> handleActionForAllSelectedItems(handler)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(() -> adapter.endSelectMode(), error -> Log.e(TAG, Log.getStackTraceString(error))); @@ -614,7 +614,7 @@ public class FeedItemlistFragment extends Fragment implements AdapterView.OnItem } return feedDownloadLog.get(0); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( downloadStatus -> DownloadLogDetailsDialog.newInstance(downloadStatus, false) @@ -669,7 +669,7 @@ public class FeedItemlistFragment extends Fragment implements AdapterView.OnItem int count = DBReader.getFeedEpisodeCount(feed.getId(), feed.getItemFilter()); return new Pair<>(feed, count); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( result -> { @@ -701,7 +701,7 @@ public class FeedItemlistFragment extends Fragment implements AdapterView.OnItem adapter.setDummyViews(1); adapter.notifyItemInserted(adapter.getItemCount() - 1); disposable = Observable.fromCallable(() -> loadMoreData(page)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( items -> { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/RemoveFeedDialog.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/RemoveFeedDialog.java index eaf5298d3..54349d261 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/RemoveFeedDialog.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/RemoveFeedDialog.java @@ -135,7 +135,7 @@ public class RemoveFeedDialog extends BottomSheetDialogFragment { DBWriter.deleteFeed(context, feed.getId()).get(); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( () -> { @@ -166,7 +166,7 @@ public class RemoveFeedDialog extends BottomSheetDialogFragment { DBWriter.setFeedState(context, feed, newState).get(); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( () -> { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/preferences/FeedSettingsFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/preferences/FeedSettingsFragment.java index b343ce974..1a179e53e 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/preferences/FeedSettingsFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/preferences/FeedSettingsFragment.java @@ -59,7 +59,7 @@ public class FeedSettingsFragment extends Fragment { emitter.onComplete(); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> toolbar.setSubtitle(result.getTitle()), error -> Log.d(TAG, Log.getStackTraceString(error)), diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/preferences/FeedSettingsPreferenceFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/preferences/FeedSettingsPreferenceFragment.java index d64612d2e..f18ebc03b 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/preferences/FeedSettingsPreferenceFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/preferences/FeedSettingsPreferenceFragment.java @@ -119,7 +119,7 @@ public class FeedSettingsPreferenceFragment extends PreferenceFragmentCompat { emitter.onComplete(); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { feed = result; diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/preferences/TagSettingsDialog.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/preferences/TagSettingsDialog.java index 4062bba0c..74e53d2af 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/preferences/TagSettingsDialog.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/feed/preferences/TagSettingsDialog.java @@ -125,7 +125,7 @@ public class TagSettingsDialog extends DialogFragment { } return folders; }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( result -> { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/HomeFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/HomeFragment.java index 081916584..77af87ce2 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/HomeFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/HomeFragment.java @@ -164,7 +164,7 @@ public class HomeFragment extends Fragment implements Toolbar.OnMenuItemClickLis disposable.dispose(); } disposable = Observable.fromCallable(() -> DBReader.getTotalEpisodeCount(FeedItemFilter.unfiltered())) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(numEpisodes -> { boolean hasEpisodes = numEpisodes != 0; diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/DownloadsSection.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/DownloadsSection.java index 7d8d3a903..3be38d401 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/DownloadsSection.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/DownloadsSection.java @@ -134,7 +134,7 @@ public class DownloadsSection extends HomeSection { } SortOrder sortOrder = UserPreferences.getDownloadsSortedOrder(); disposable = Observable.fromCallable(() -> DBReader.getEpisodes(0, NUM_EPISODES, FILTER_DOWNLOADED, sortOrder)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(downloads -> { items = downloads; diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/EchoSection.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/EchoSection.java index 2aa377bb6..37bebcf9d 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/EchoSection.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/EchoSection.java @@ -52,7 +52,7 @@ public class EchoSection extends Fragment { } return totalTime; }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(totalTime -> { boolean shouldShow = (totalTime >= 3600 * 10); diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/EpisodesSurpriseSection.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/EpisodesSurpriseSection.java index 89cbfb9cf..bde6c0e13 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/EpisodesSurpriseSection.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/EpisodesSurpriseSection.java @@ -150,7 +150,7 @@ public class EpisodesSurpriseSection extends HomeSection { disposable.dispose(); } disposable = Observable.fromCallable(() -> DBReader.getRandomEpisodes(NUM_EPISODES, seed)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(episodes -> { this.episodes = episodes; diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/InboxSection.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/InboxSection.java index bd31f9fcd..908788c46 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/InboxSection.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/InboxSection.java @@ -127,7 +127,7 @@ public class InboxSection extends HomeSection { new Pair<>(DBReader.getEpisodes(0, NUM_EPISODES, new FeedItemFilter(FeedItemFilter.NEW), UserPreferences.getInboxSortedOrder()), DBReader.getTotalEpisodeCount(new FeedItemFilter(FeedItemFilter.NEW)))) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(data -> { items = data.first; diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/QueueSection.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/QueueSection.java index 78779be92..83e448165 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/QueueSection.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/QueueSection.java @@ -151,7 +151,7 @@ public class QueueSection extends HomeSection { disposable.dispose(); } disposable = Observable.fromCallable(() -> DBReader.getPausedQueue(NUM_EPISODES)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(queue -> { this.queue = queue; diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/SubscriptionsSection.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/SubscriptionsSection.java index 117916792..249c7cdd8 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/SubscriptionsSection.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/home/sections/SubscriptionsSection.java @@ -99,7 +99,7 @@ public class SubscriptionsSection extends HomeSection { long threeYearsAgo = System.currentTimeMillis() - 3L * 365L * 24L * 60L * 60L * 1000L; disposable = Observable.fromCallable(() -> DBReader.getStatistics(includeMarkedAsPlayed, threeYearsAgo, Long.MAX_VALUE).feedTime) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(statisticsData -> { Collections.sort(statisticsData, (item1, item2) -> diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/onlinefeedview/OnlineFeedViewActivity.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/onlinefeedview/OnlineFeedViewActivity.java index a68a513e1..2a3fedb24 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/onlinefeedview/OnlineFeedViewActivity.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/onlinefeedview/OnlineFeedViewActivity.java @@ -232,7 +232,7 @@ public class OnlineFeedViewActivity extends AppCompatActivity { } return null; }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(subscribedFeed -> { if (subscribedFeed.getState() == Feed.STATE_NOT_SUBSCRIBED) { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/SleepTimerDialog.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/SleepTimerDialog.java index 782a25a6b..c9535240a 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/SleepTimerDialog.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/SleepTimerDialog.java @@ -97,7 +97,7 @@ public class SleepTimerDialog extends BottomSheetDialogFragment { } return DBReader.getRemainingQueueSize(media.getItemId()); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { currentQueueSize = result; diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/TranscriptDialogFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/TranscriptDialogFragment.java index 50bc96959..9886685b6 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/TranscriptDialogFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/TranscriptDialogFragment.java @@ -187,7 +187,7 @@ public class TranscriptDialogFragment extends DialogFragment emitter.onComplete(); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(media -> onMediaChanged((Playable) media), error -> Log.e(TAG, Log.getStackTraceString(error))); diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/VariableSpeedDialog.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/VariableSpeedDialog.java index 33a86afb3..84643f750 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/VariableSpeedDialog.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/VariableSpeedDialog.java @@ -89,7 +89,7 @@ public class VariableSpeedDialog extends BottomSheetDialogFragment { // Make sure the media is loaded in case getCurrentPlaybackSpeedMultiplier has to access it return controller.getMedia(); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(pair -> { if (controller == null) { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/AudioPlayerFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/AudioPlayerFragment.java index b33a1735e..ceb87804d 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/AudioPlayerFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/AudioPlayerFragment.java @@ -291,7 +291,7 @@ public class AudioPlayerFragment extends Fragment implements emitter.onComplete(); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(media -> { currentMedia = media; diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/CoverFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/CoverFragment.java index cb812e10f..5757369fc 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/CoverFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/CoverFragment.java @@ -119,7 +119,7 @@ public class CoverFragment extends Fragment { } else { emitter.onComplete(); } - }).subscribeOn(Schedulers.io()) + }).subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(media -> { this.media = media; diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/ExternalPlayerFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/ExternalPlayerFragment.java index 89855497a..dae384cd7 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/ExternalPlayerFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/ExternalPlayerFragment.java @@ -153,7 +153,7 @@ public class ExternalPlayerFragment extends Fragment { } disposable = Maybe.fromCallable( () -> DBReader.getFeedMedia(PlaybackPreferences.getCurrentlyPlayingFeedMediaId())) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(this::updateUi, error -> Log.e(TAG, Log.getStackTraceString(error)), diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/ItemDescriptionFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/ItemDescriptionFragment.java index 418781763..b78a07e5c 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/ItemDescriptionFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/audio/ItemDescriptionFragment.java @@ -112,7 +112,7 @@ public class ItemDescriptionFragment extends Fragment { context, media.getDescription(), media.getDuration()); emitter.onSuccess(shownotesCleaner.processShownotes()); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(data -> { if (TextUtils.equals(loadedData, data)) { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/video/VideoplayerActivity.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/video/VideoplayerActivity.java index 50abd4508..83a67ad28 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/video/VideoplayerActivity.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/playback/video/VideoplayerActivity.java @@ -302,7 +302,7 @@ public class VideoplayerActivity extends CastEnabledActivity } emitter.onSuccess(new Pair<>(media, feedItem)); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( result -> { diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/preferences/ImportExportPreferencesFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/preferences/ImportExportPreferencesFragment.java index 9a72a45ab..68426c8a2 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/preferences/ImportExportPreferencesFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/preferences/ImportExportPreferencesFragment.java @@ -245,7 +245,7 @@ public class ImportExportPreferencesFragment extends AnimatedPreferenceFragment final Uri uri = result.getData().getData(); progressDialog.show(); disposable = Completable.fromAction(() -> DatabaseExporter.importBackup(uri, getContext())) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(() -> { showDatabaseImportSuccessDialog(); @@ -259,7 +259,7 @@ public class ImportExportPreferencesFragment extends AnimatedPreferenceFragment } progressDialog.show(); disposable = Completable.fromAction(() -> DatabaseExporter.exportToDocument(uri, getContext())) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(() -> { showExportSuccessSnackbar(uri, "application/x-sqlite3"); @@ -306,7 +306,7 @@ public class ImportExportPreferencesFragment extends AnimatedPreferenceFragment subscriber.onError(e); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(outputFile -> { progressDialog.dismiss(); @@ -332,7 +332,7 @@ public class ImportExportPreferencesFragment extends AnimatedPreferenceFragment subscriber.onError(e); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(ignore -> { progressDialog.dismiss(); diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/queue/QueueFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/queue/QueueFragment.java index fe938eddd..6f9f6bc91 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/queue/QueueFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/queue/QueueFragment.java @@ -533,7 +533,7 @@ public class QueueFragment extends Fragment implements MaterialToolbar.OnMenuIte boolean displayGoToInboxButton = DBReader.getTotalEpisodeCount(new FeedItemFilter(FeedItemFilter.NEW)) > 0; return new Pair<>(DBReader.getQueue(), displayGoToInboxButton); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(itemsAndDisplayButton -> { final boolean restoreScrollPosition = queue == null || queue.isEmpty(); diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/rating/RatingDialogManager.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/rating/RatingDialogManager.java index 246bc7a16..2038a56ed 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/rating/RatingDialogManager.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/rating/RatingDialogManager.java @@ -52,7 +52,7 @@ public class RatingDialogManager { } return new Pair<>(totalTime, statisticsData.oldestDate); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { long totalTime = result.getFirst(); diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/subscriptions/FeedMultiSelectActionHandler.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/subscriptions/FeedMultiSelectActionHandler.java index 0d0d0c97f..fe07f3307 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/subscriptions/FeedMultiSelectActionHandler.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/subscriptions/FeedMultiSelectActionHandler.java @@ -168,7 +168,7 @@ public class FeedMultiSelectActionHandler { DBWriter.removeFeedNewFlag(selectedFeed.getId()); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { }, error -> Log.e(TAG, Log.getStackTraceString(error))); } diff --git a/app/src/main/java/de/danoeh/antennapod/ui/screen/subscriptions/SubscriptionFragment.java b/app/src/main/java/de/danoeh/antennapod/ui/screen/subscriptions/SubscriptionFragment.java index 81e2fd9a1..1bc764066 100644 --- a/app/src/main/java/de/danoeh/antennapod/ui/screen/subscriptions/SubscriptionFragment.java +++ b/app/src/main/java/de/danoeh/antennapod/ui/screen/subscriptions/SubscriptionFragment.java @@ -374,7 +374,7 @@ public class SubscriptionFragment extends Fragment List tags = DBReader.getAllTags(stateToShow); return new Pair<>(navDrawerData, tags); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( result -> { diff --git a/net/discovery/src/main/java/de/danoeh/antennapod/net/discovery/FyydPodcastSearcher.java b/net/discovery/src/main/java/de/danoeh/antennapod/net/discovery/FyydPodcastSearcher.java index 1bf5460b2..82a81bdd5 100644 --- a/net/discovery/src/main/java/de/danoeh/antennapod/net/discovery/FyydPodcastSearcher.java +++ b/net/discovery/src/main/java/de/danoeh/antennapod/net/discovery/FyydPodcastSearcher.java @@ -65,7 +65,7 @@ public class FyydPodcastSearcher implements PodcastSearcher { } subscriber.onSuccess(searchResults); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()); } diff --git a/net/download/service/src/main/java/de/danoeh/antennapod/net/download/service/feed/DownloadServiceInterfaceImpl.java b/net/download/service/src/main/java/de/danoeh/antennapod/net/download/service/feed/DownloadServiceInterfaceImpl.java index 20b26f8aa..5a50560c3 100644 --- a/net/download/service/src/main/java/de/danoeh/antennapod/net/download/service/feed/DownloadServiceInterfaceImpl.java +++ b/net/download/service/src/main/java/de/danoeh/antennapod/net/download/service/feed/DownloadServiceInterfaceImpl.java @@ -78,8 +78,8 @@ public class DownloadServiceInterfaceImpl extends DownloadServiceInterface { String tag = WORK_TAG_EPISODE_URL + media.getDownloadUrl(); Future> 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) { diff --git a/net/sync/service/src/main/java/de/danoeh/antennapod/net/sync/service/LockingAsyncExecutor.java b/net/sync/service/src/main/java/de/danoeh/antennapod/net/sync/service/LockingAsyncExecutor.java index a78d4e72d..715e47b20 100644 --- a/net/sync/service/src/main/java/de/danoeh/antennapod/net/sync/service/LockingAsyncExecutor.java +++ b/net/sync/service/src/main/java/de/danoeh/antennapod/net/sync/service/LockingAsyncExecutor.java @@ -28,7 +28,7 @@ public class LockingAsyncExecutor { } finally { lock.unlock(); } - }).subscribeOn(Schedulers.io()) + }).subscribeOn(Schedulers.computation()) .subscribe(); } } diff --git a/playback/service/src/main/java/de/danoeh/antennapod/playback/service/PlaybackService.java b/playback/service/src/main/java/de/danoeh/antennapod/playback/service/PlaybackService.java index 8868cc250..faf7f96c4 100644 --- a/playback/service/src/main/java/de/danoeh/antennapod/playback/service/PlaybackService.java +++ b/playback/service/src/main/java/de/danoeh/antennapod/playback/service/PlaybackService.java @@ -376,7 +376,7 @@ public class PlaybackService extends MediaBrowserServiceCompat { } emitter.onSuccess(queueItems); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(queueItems -> mediaSession.setQueue(queueItems), Throwable::printStackTrace); singleShotDisposables.add(d); @@ -436,7 +436,7 @@ public class PlaybackService extends MediaBrowserServiceCompat { result.sendResult(loadChildrenSynchronous(parentId)); emitter.onComplete(); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( () -> { @@ -578,7 +578,7 @@ public class PlaybackService extends MediaBrowserServiceCompat { return playable; } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( loadedPlayable -> startPlaying(loadedPlayable, allowStreamThisTime), @@ -775,7 +775,7 @@ public class PlaybackService extends MediaBrowserServiceCompat { private void startPlayingFromPreferences() { Disposable d = Observable.fromCallable(() -> DBReader.getFeedMedia(PlaybackPreferences.getCurrentlyPlayingFeedMediaId())) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( playable -> startPlaying(playable, false), diff --git a/playback/service/src/main/java/de/danoeh/antennapod/playback/service/internal/PlaybackServiceTaskManager.java b/playback/service/src/main/java/de/danoeh/antennapod/playback/service/internal/PlaybackServiceTaskManager.java index 0b79515a2..fab5780e5 100644 --- a/playback/service/src/main/java/de/danoeh/antennapod/playback/service/internal/PlaybackServiceTaskManager.java +++ b/playback/service/src/main/java/de/danoeh/antennapod/playback/service/internal/PlaybackServiceTaskManager.java @@ -160,7 +160,7 @@ public class PlaybackServiceTaskManager { ChapterUtils.loadChapters(media, context, false); emitter.onComplete(); }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(() -> callback.onChapterLoaded(media), throwable -> Log.d(TAG, "Error loading chapters: " + Log.getStackTraceString(throwable))); diff --git a/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/EchoActivity.java b/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/EchoActivity.java index a0def88d6..b89ac33f4 100644 --- a/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/EchoActivity.java +++ b/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/EchoActivity.java @@ -88,7 +88,7 @@ public class EchoActivity extends AppCompatActivity { protected void onStart() { super.onStart(); redrawTimer = Flowable.timer(20, TimeUnit.MILLISECONDS) - .observeOn(Schedulers.io()) + .observeOn(Schedulers.computation()) .repeat() .subscribe(i -> { if (progressPaused) { @@ -143,7 +143,7 @@ public class EchoActivity extends AppCompatActivity { Long.compare(item2.timePlayed, item1.timePlayed)); return statisticsData; }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { for (EchoScreen screen : screens) { diff --git a/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/screen/FinalShareScreen.java b/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/screen/FinalShareScreen.java index ed8d7fb64..0ce8fdac1 100644 --- a/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/screen/FinalShareScreen.java +++ b/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/screen/FinalShareScreen.java @@ -119,7 +119,7 @@ public class FinalShareScreen extends EchoScreen { } return statisticsData; }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { }, error -> Log.e(TAG, Log.getStackTraceString(error))); diff --git a/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/screen/QueueScreen.java b/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/screen/QueueScreen.java index af2da2af2..07051d9f0 100644 --- a/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/screen/QueueScreen.java +++ b/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/screen/QueueScreen.java @@ -76,7 +76,7 @@ public class QueueScreen extends EchoScreen { disposable.dispose(); } disposable = Observable.fromCallable(DBReader::getQueue) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(queue -> { long queueSecondsLeft = 0; diff --git a/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/screen/TimeReleasePlayScreen.java b/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/screen/TimeReleasePlayScreen.java index 06f208b0d..31bc73d21 100644 --- a/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/screen/TimeReleasePlayScreen.java +++ b/ui/echo/src/main/java/de/danoeh/antennapod/ui/echo/screen/TimeReleasePlayScreen.java @@ -58,7 +58,7 @@ public class TimeReleasePlayScreen extends EchoScreen { } disposable = Observable.fromCallable(() -> DBReader.getTimeBetweenReleaseAndPlayback(EchoConfig.jan1(), Long.MAX_VALUE)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(this::display, error -> Log.e(TAG, Log.getStackTraceString(error))); } diff --git a/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/DevelopersFragment.java b/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/DevelopersFragment.java index 96fda46bb..0a1369cde 100644 --- a/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/DevelopersFragment.java +++ b/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/DevelopersFragment.java @@ -43,7 +43,7 @@ public class DevelopersFragment extends ListFragment { emitter.onError(e); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( developers -> setListAdapter(new SimpleIconListAdapter<>(getContext(), developers)), diff --git a/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/LicensesFragment.java b/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/LicensesFragment.java index 8de39069b..ab02c5993 100644 --- a/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/LicensesFragment.java +++ b/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/LicensesFragment.java @@ -65,7 +65,7 @@ public class LicensesFragment extends ListFragment { emitter.onError(e); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( developers -> setListAdapter(new SimpleIconListAdapter(getContext(), developers)), diff --git a/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/SpecialThanksFragment.java b/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/SpecialThanksFragment.java index bced36b79..354ec46a9 100644 --- a/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/SpecialThanksFragment.java +++ b/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/SpecialThanksFragment.java @@ -43,7 +43,7 @@ public class SpecialThanksFragment extends ListFragment { emitter.onError(e); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( translators -> setListAdapter(new SimpleIconListAdapter<>(getContext(), translators)), diff --git a/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/TranslatorsFragment.java b/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/TranslatorsFragment.java index d906a8d54..57f954145 100644 --- a/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/TranslatorsFragment.java +++ b/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/about/TranslatorsFragment.java @@ -39,7 +39,7 @@ public class TranslatorsFragment extends ListFragment { emitter.onError(e); } }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( translators -> setListAdapter(new SimpleIconListAdapter<>(getContext(), translators)), diff --git a/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/bugreport/BugReportViewModel.java b/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/bugreport/BugReportViewModel.java index b61d13d3b..1ea283b26 100644 --- a/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/bugreport/BugReportViewModel.java +++ b/ui/preferences/src/main/java/de/danoeh/antennapod/ui/preferences/screen/bugreport/BugReportViewModel.java @@ -173,7 +173,7 @@ public class BugReportViewModel extends AndroidViewModel { super(application); // Does file I/O, so we have to use a background thread this.disposable = Observable.fromCallable(() -> new UiState(application)) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .subscribe(this.uiState::postValue); } diff --git a/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/StatisticsFragment.java b/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/StatisticsFragment.java index 7db5d6d6a..d5d115ffc 100644 --- a/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/StatisticsFragment.java +++ b/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/StatisticsFragment.java @@ -140,7 +140,7 @@ public class StatisticsFragment extends PagedToolbarFragment { .apply(); Disposable disposable = Completable.fromFuture(DBWriter.resetStatistics()) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(() -> EventBus.getDefault().post(new StatisticsEvent()), error -> Log.e(TAG, Log.getStackTraceString(error))); diff --git a/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/downloads/DownloadStatisticsFragment.java b/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/downloads/DownloadStatisticsFragment.java index 8d69d75ad..bb0e33c5e 100644 --- a/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/downloads/DownloadStatisticsFragment.java +++ b/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/downloads/DownloadStatisticsFragment.java @@ -79,7 +79,7 @@ public class DownloadStatisticsFragment extends Fragment { Long.compare(item2.totalDownloadSize, item1.totalDownloadSize)); return statisticsData; }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { listAdapter.update(result.feedTime); diff --git a/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/feed/FeedStatisticsFragment.java b/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/feed/FeedStatisticsFragment.java index de6540e42..a8c4267ed 100644 --- a/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/feed/FeedStatisticsFragment.java +++ b/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/feed/FeedStatisticsFragment.java @@ -95,7 +95,7 @@ public class FeedStatisticsFragment extends Fragment { } return null; }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(this::showStats, Throwable::printStackTrace); } diff --git a/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/subscriptions/SubscriptionStatisticsFragment.java b/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/subscriptions/SubscriptionStatisticsFragment.java index 8264aeb55..be2a31c9e 100644 --- a/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/subscriptions/SubscriptionStatisticsFragment.java +++ b/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/subscriptions/SubscriptionStatisticsFragment.java @@ -121,7 +121,7 @@ public class SubscriptionStatisticsFragment extends Fragment { Long.compare(item2.timePlayed, item1.timePlayed)); return statisticsData; }) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { statisticsResult = result; diff --git a/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/years/YearsStatisticsFragment.java b/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/years/YearsStatisticsFragment.java index b0a47ea6b..7a73eb591 100644 --- a/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/years/YearsStatisticsFragment.java +++ b/ui/statistics/src/main/java/de/danoeh/antennapod/ui/statistics/years/YearsStatisticsFragment.java @@ -86,7 +86,7 @@ public class YearsStatisticsFragment extends Fragment { disposable.dispose(); } disposable = Observable.fromCallable(DBReader::getMonthlyTimeStatistics) - .subscribeOn(Schedulers.io()) + .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(result -> { listAdapter.update(result);