Skip to content
This repository was archived by the owner on Feb 17, 2020. It is now read-only.

Commit f902bc0

Browse files
committed
Avoid relying on default schedulers
1 parent fd7994b commit f902bc0

2 files changed

Lines changed: 3 additions & 1 deletion

File tree

app/src/main/java/net/squanchy/onboarding/account/AccountOnboardingActivity.kt

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ import android.os.Bundle
66
import android.support.v7.app.AppCompatActivity
77
import io.reactivex.android.schedulers.AndroidSchedulers
88
import io.reactivex.disposables.Disposable
9+
import io.reactivex.schedulers.Schedulers
910
import kotlinx.android.synthetic.main.activity_onboarding_account.*
1011
import net.squanchy.R
1112
import net.squanchy.navigation.Navigator
@@ -46,6 +47,7 @@ class AccountOnboardingActivity : AppCompatActivity() {
4647

4748
disableUi()
4849
subscription = signInService.isSignedInToGoogle()
50+
.subscribeOn(Schedulers.io())
4951
.observeOn(AndroidSchedulers.mainThread())
5052
.timeout(SIGNIN_STATE_CHECK_TIMEOUT_SECONDS, TimeUnit.SECONDS)
5153
.subscribe(

app/src/main/java/net/squanchy/search/SearchActivity.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ class SearchActivity : AppCompatActivity(), SearchRecyclerView.OnSearchResultCli
7676
searchTextWatcher = SearchTextWatcher(querySubject)
7777
searchField.addTextChangedListener(searchTextWatcher)
7878

79-
val searchSubscription = querySubject.throttleLast(QUERY_DEBOUNCE_TIMEOUT, TimeUnit.MILLISECONDS)
79+
val searchSubscription = querySubject.throttleLast(QUERY_DEBOUNCE_TIMEOUT, TimeUnit.MILLISECONDS, Schedulers.computation())
8080
.doOnNext(::updateSearchActionIcon)
8181
.startWith(query)
8282
.doOnNext { query = it }

0 commit comments

Comments
 (0)