+2
-2
@@ -31,8 +31,8 @@ class MigrateMangaPresenter(
|
||||
presenterScope.launchIO {
|
||||
getFavorites
|
||||
.subscribe(sourceId)
|
||||
.catch { exception ->
|
||||
logcat(LogPriority.ERROR, exception)
|
||||
.catch {
|
||||
logcat(LogPriority.ERROR, it)
|
||||
_events.send(Event.FailedFetchingFavorites)
|
||||
}
|
||||
.map { list ->
|
||||
|
||||
+2
-2
@@ -32,8 +32,8 @@ class MigrationSourcesPresenter(
|
||||
fun onCreate() {
|
||||
presenterScope.launchIO {
|
||||
getSourcesWithFavoriteCount.subscribe()
|
||||
.catch { exception ->
|
||||
logcat(LogPriority.ERROR, exception)
|
||||
.catch {
|
||||
logcat(LogPriority.ERROR, it)
|
||||
_channel.send(Event.FailedFetchingSourcesWithCount)
|
||||
}
|
||||
.collectLatest { sources ->
|
||||
|
||||
@@ -40,8 +40,8 @@ class SourcesPresenter(
|
||||
fun onCreate() {
|
||||
presenterScope.launchIO {
|
||||
getEnabledSources.subscribe()
|
||||
.catch { exception ->
|
||||
logcat(LogPriority.ERROR, exception)
|
||||
.catch {
|
||||
logcat(LogPriority.ERROR, it)
|
||||
_events.send(Event.FailedFetchingSources)
|
||||
}
|
||||
.onStart { delay(500) } // Defer to avoid crashing on initial render
|
||||
|
||||
Reference in New Issue
Block a user