chore: 🔧 specify schedulers for network/database operations.

Author: ffgiraldez

app/src/main/java/es/ffgiraldez/comicsearch/platform/ComicSchedulers.kt

@@ -0,0 +1,9 @@
+package es.ffgiraldez.comicsearch.platform
+
+import io.reactivex.Scheduler
+import io.reactivex.schedulers.Schedulers
+
+object ComicSchedulers {
+    val database: Scheduler = Schedulers.single()
+    val network: Scheduler = Schedulers.io()
+}

app/src/main/java/es/ffgiraldez/comicsearch/query/search/data/SearchDataSources.kt

@@ -5,9 +5,10 @@ import arrow.core.toOption
 import es.ffgiraldez.comicsearch.comics.data.ComicLocalDataSource
 import es.ffgiraldez.comicsearch.comics.data.ComicRemoteDataSource
 import es.ffgiraldez.comicsearch.comics.data.network.ComicVineApi
+import es.ffgiraldez.comicsearch.comics.data.storage.ComicDatabase
 import es.ffgiraldez.comicsearch.comics.domain.Query
 import es.ffgiraldez.comicsearch.comics.domain.Volume
-import es.ffgiraldez.comicsearch.comics.data.storage.ComicDatabase
+import es.ffgiraldez.comicsearch.platform.ComicSchedulers
 import io.reactivex.Completable
 import io.reactivex.Flowable
 import io.reactivex.Single
@@ -17,7 +18,7 @@ class SearchRemoteDataSource(
         private val api: ComicVineApi
 ) : ComicRemoteDataSource<Volume> {
     override fun findByTerm(searchTerm: String): Single<List<Volume>> = api.fetchVolumes(searchTerm)
-            .subscribeOn(Schedulers.io())
+            .subscribeOn(ComicSchedulers.network)
             .map { response ->
                 response.results
                         .filter { it.apiPublisher != null && it.apiImage != null }
@@ -33,15 +34,17 @@ class SearchLocalDataSource(
     override fun insert(query: String, titles: List<Volume>): Completable =
             Completable.fromAction {
                 database.volumeDao().insert(query, titles)
-            }.subscribeOn(Schedulers.io())
+            }.subscribeOn(ComicSchedulers.database)
 
     override fun findQueryByTerm(searchTerm: String): Flowable<Option<Query>> = database.volumeDao()
             .findQueryByTerm(searchTerm)
+            .subscribeOn(ComicSchedulers.database)
             .flatMap { Flowable.just(it.firstOrNull().toOption()) }
             .map { search -> search.map { Query(it.queryId, it.searchTerm) } }
 
     override fun findByQuery(query: Query): Flowable<List<Volume>> = database.volumeDao()
             .findVolumeByQuery(query.identifier)
+            .subscribeOn(ComicSchedulers.database)
             .subscribeOn(Schedulers.io())
             .map { volumeList -> volumeList.map { Volume(it.title, it.author, it.url) } }
 }

app/src/main/java/es/ffgiraldez/comicsearch/query/sugestion/data/SuggestionDataSources.kt

@@ -5,19 +5,18 @@ import arrow.core.toOption
 import es.ffgiraldez.comicsearch.comics.data.ComicLocalDataSource
 import es.ffgiraldez.comicsearch.comics.data.ComicRemoteDataSource
 import es.ffgiraldez.comicsearch.comics.data.network.ComicVineApi
-import es.ffgiraldez.comicsearch.comics.domain.Query
 import es.ffgiraldez.comicsearch.comics.data.storage.ComicDatabase
+import es.ffgiraldez.comicsearch.comics.domain.Query
+import es.ffgiraldez.comicsearch.platform.ComicSchedulers
 import io.reactivex.Completable
 import io.reactivex.Flowable
 import io.reactivex.Single
-import io.reactivex.schedulers.Schedulers
-
 
 class SuggestionRemoteDataSource(
         private val api: ComicVineApi
 ) : ComicRemoteDataSource<String> {
     override fun findByTerm(searchTerm: String): Single<List<String>> = api.fetchVolumes(searchTerm)
-            .subscribeOn(Schedulers.io())
+            .subscribeOn(ComicSchedulers.network)
             .map { response ->
                 response.results
                         .distinctBy { it.name }
@@ -31,16 +30,16 @@ class SuggestionLocalDataSource(
     override fun insert(query: String, titles: List<String>): Completable =
             Completable.fromAction {
                 database.suggestionDao().insert(query, titles)
-            }.subscribeOn(Schedulers.io())
+            }.subscribeOn(ComicSchedulers.database)
 
     override fun findQueryByTerm(searchTerm: String): Flowable<Option<Query>> = database.suggestionDao()
             .findQueryByTerm(searchTerm)
-            .subscribeOn(Schedulers.io())
+            .subscribeOn(ComicSchedulers.database)
             .flatMap { Flowable.just(it.firstOrNull().toOption()) }
             .map { search -> search.map { Query(it.queryId, it.searchTerm) } }
 
     override fun findByQuery(query: Query): Flowable<List<String>> = database.suggestionDao()
             .findSuggestionByQuery(query.identifier)
-            .subscribeOn(Schedulers.io())
+            .subscribeOn(ComicSchedulers.database)
             .map { suggestions -> suggestions.map { it.title } }
 }