mirrors/bitwarden-android
1
0
Fork 0
mirror of https://github.com/bitwarden/android.git synced 2025-03-16 03:08:50 +03:00
Code Issues Projects Releases Packages Wiki Activity

BIT-1229: Use Unconfined dispatcher when collecting flows in AuthRepository (#410)

Browse source
This commit is contained in:
Brian Yencho 2023-12-18 11:54:04 -06:00 • committed by Álison Fernandes
parent 6fc4eb8b90
commit fb8eab13d0
1 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
app/src/main/java/com/x8bit/bitwarden/data/auth/repository/AuthRepositoryImpl.kt
View file

@ -34,6 +34,7 @@ import com.x8bit.bitwarden.data.platform.util.asFailure
import com.x8bit.bitwarden.data.platform.util.flatMap
import com.x8bit.bitwarden.data.vault.repository.VaultRepository
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.MutableSharedFlow
import kotlinx.coroutines.flow.MutableStateFlow
@ -62,7 +63,13 @@ class AuthRepositoryImpl constructor(
) : AuthRepository {
private val mutableSpecialCircumstanceStateFlow =
MutableStateFlow<UserState.SpecialCircumstance?>(null)
private val scope = CoroutineScope(dispatcherManager.io)
/**
* A scope intended for use when simply collecting multiple flows in order to combine them. The
* use of [Dispatchers.Unconfined] allows for this to happen synchronously whenever any of
* these flows changes.
*/
private val collectionScope = CoroutineScope(dispatcherManager.unconfined)
override val activeUserId: String? get() = authDiskSource.userState?.activeUserId
@ -81,7 +88,7 @@ class AuthRepositoryImpl constructor(
?: AuthState.Unauthenticated
}
.stateIn(
scope = scope,
scope = collectionScope,
started = SharingStarted.Eagerly,
initialValue = AuthState.Uninitialized,
)
@ -98,7 +105,7 @@ class AuthRepositoryImpl constructor(
)
}
.stateIn(
scope = scope,
scope = collectionScope,
started = SharingStarted.Eagerly,
initialValue = authDiskSource
.userState