Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 4211c8a8 authored by Ale Nijamkin's avatar Ale Nijamkin Committed by Automerger Merge Worker
Browse files

Merge "More eagerly collect isSimpleUserSwitcher." into tm-qpr-dev am: fc2e8ed2 

Original change: https://googleplex-android-review.googlesource.com/c/platform/frameworks/base/+/21336505



Change-Id: Iba35e4b61c4972f5129efffc3edb1ad6c89072b2
Signed-off-by: default avatarAutomerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
parents aed20ab0 fc2e8ed2

packages/SystemUI/src/com/android/systemui/user/data/repository/UserRepository.kt

+22 −22
Original line number Diff line number Diff line
@@ -47,12 +47,14 @@ import kotlinx.coroutines.asExecutor 
import kotlinx.coroutines.channels.awaitClose

import kotlinx.coroutines.flow.Flow

import kotlinx.coroutines.flow.MutableStateFlow

import kotlinx.coroutines.flow.asStateFlow

import kotlinx.coroutines.flow.SharingStarted

import kotlinx.coroutines.flow.StateFlow

import kotlinx.coroutines.flow.filterNotNull

import kotlinx.coroutines.flow.launchIn

import kotlinx.coroutines.flow.map

import kotlinx.coroutines.flow.onEach

import kotlinx.coroutines.flow.onStart

import kotlinx.coroutines.flow.stateIn

import kotlinx.coroutines.launch

import kotlinx.coroutines.runBlocking

import kotlinx.coroutines.withContext
@@ -120,9 +122,25 @@ constructor( 
    featureFlags: FeatureFlags,

) : UserRepository {



    private val _userSwitcherSettings = MutableStateFlow(runBlocking { getSettings() })

    override val userSwitcherSettings: Flow<UserSwitcherSettingsModel> =

        _userSwitcherSettings.asStateFlow().filterNotNull()

    private val _userSwitcherSettings: StateFlow<UserSwitcherSettingsModel> =

        globalSettings

            .observerFlow(

                names =

                    arrayOf(

                        SETTING_SIMPLE_USER_SWITCHER,

                        Settings.Global.ADD_USERS_WHEN_LOCKED,

                        Settings.Global.USER_SWITCHER_ENABLED,

                    ),

                userId = UserHandle.USER_SYSTEM,

            )

            .onStart { emit(Unit) } // Forces an initial update.

            .map { getSettings() }

            .stateIn(

                scope = applicationScope,

                started = SharingStarted.Eagerly,

                initialValue = runBlocking { getSettings() },

            )

    override val userSwitcherSettings: Flow<UserSwitcherSettingsModel> = _userSwitcherSettings



    private val _userInfos = MutableStateFlow<List<UserInfo>?>(null)

    override val userInfos: Flow<List<UserInfo>> = _userInfos.filterNotNull()
@@ -154,7 +172,6 @@ constructor( 


    init {

        observeSelectedUser()

        observeUserSettings()

        if (featureFlags.isEnabled(FACE_AUTH_REFACTOR)) {

            observeUserSwitching()

        }
@@ -237,23 +254,6 @@ constructor( 
            .launchIn(applicationScope)

    }



    private fun observeUserSettings() {

        globalSettings

            .observerFlow(

                names =

                    arrayOf(

                        SETTING_SIMPLE_USER_SWITCHER,

                        Settings.Global.ADD_USERS_WHEN_LOCKED,

                        Settings.Global.USER_SWITCHER_ENABLED,

                    ),

                userId = UserHandle.USER_SYSTEM,

            )

            .onStart { emit(Unit) } // Forces an initial update.

            .map { getSettings() }

            .onEach { _userSwitcherSettings.value = it }

            .launchIn(applicationScope)

    }



    private suspend fun getSettings(): UserSwitcherSettingsModel {

        return withContext(backgroundDispatcher) {

            val isSimpleUserSwitcher =