diff --git a/app/src/main/java/gq/kirmanak/mealient/data/auth/impl/AuthStorageImpl.kt b/app/src/main/java/gq/kirmanak/mealient/data/auth/impl/AuthStorageImpl.kt index ac82edc..9762c61 100644 --- a/app/src/main/java/gq/kirmanak/mealient/data/auth/impl/AuthStorageImpl.kt +++ b/app/src/main/java/gq/kirmanak/mealient/data/auth/impl/AuthStorageImpl.kt @@ -6,7 +6,6 @@ import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.ExperimentalCoroutinesApi import kotlinx.coroutines.channels.awaitClose import kotlinx.coroutines.channels.onFailure -import kotlinx.coroutines.channels.trySendBlocking import kotlinx.coroutines.flow.Flow import kotlinx.coroutines.flow.callbackFlow import kotlinx.coroutines.withContext @@ -57,7 +56,7 @@ class AuthStorageImpl @Inject constructor( else -> return@OnSharedPreferenceChangeListener } Timber.d("tokenObservable: New token: $token") - trySendBlocking(token).onFailure { Timber.e(it, "Can't send new token") } + trySend(token).onFailure { Timber.e(it, "Can't send new token") } } Timber.v("tokenObservable: registering listener") send(getToken()) diff --git a/app/src/main/java/gq/kirmanak/mealient/ui/SwipeRefreshLayoutHelper.kt b/app/src/main/java/gq/kirmanak/mealient/ui/SwipeRefreshLayoutHelper.kt index 5f318d7..8e76496 100644 --- a/app/src/main/java/gq/kirmanak/mealient/ui/SwipeRefreshLayoutHelper.kt +++ b/app/src/main/java/gq/kirmanak/mealient/ui/SwipeRefreshLayoutHelper.kt @@ -6,7 +6,6 @@ import androidx.swiperefreshlayout.widget.SwipeRefreshLayout import kotlinx.coroutines.ExperimentalCoroutinesApi import kotlinx.coroutines.channels.awaitClose import kotlinx.coroutines.channels.onFailure -import kotlinx.coroutines.channels.trySendBlocking import kotlinx.coroutines.flow.Flow import kotlinx.coroutines.flow.callbackFlow import kotlinx.coroutines.flow.collectLatest @@ -19,7 +18,7 @@ object SwipeRefreshLayoutHelper { return callbackFlow { val listener = SwipeRefreshLayout.OnRefreshListener { Timber.v("Refresh requested") - trySendBlocking(Unit).onFailure { Timber.e(it, "Can't send refresh callback") } + trySend(Unit).onFailure { Timber.e(it, "Can't send refresh callback") } } Timber.v("Adding refresh request listener") setOnRefreshListener(listener)