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

Commit 1710a261 authored by Evan Laird's avatar Evan Laird Committed by Android (Google) Code Review
Browse files

Merge "[Mobile] Don't return StateFlow from method" into main

parents 94f26f38 f9027a59
Loading
Loading
Loading
Loading
+3 −2
Original line number Diff line number Diff line
@@ -27,6 +27,7 @@ import com.android.systemui.statusbar.pipeline.mobile.data.repository.MobileConn
import javax.inject.Inject
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.MutableStateFlow
import kotlinx.coroutines.flow.SharingStarted
import kotlinx.coroutines.flow.StateFlow
@@ -48,7 +49,7 @@ class FullMobileConnectionRepository(
    override val subId: Int,
    startingIsCarrierMerged: Boolean,
    override val tableLogBuffer: TableLogBuffer,
    subscriptionModel: StateFlow<SubscriptionModel?>,
    subscriptionModel: Flow<SubscriptionModel?>,
    private val defaultNetworkName: NetworkNameModel,
    private val networkNameSeparator: String,
    @Application scope: CoroutineScope,
@@ -331,7 +332,7 @@ class FullMobileConnectionRepository(
        fun build(
            subId: Int,
            startingIsCarrierMerged: Boolean,
            subscriptionModel: StateFlow<SubscriptionModel?>,
            subscriptionModel: Flow<SubscriptionModel?>,
            defaultNetworkName: NetworkNameModel,
            networkNameSeparator: String,
        ): FullMobileConnectionRepository {
+2 −2
Original line number Diff line number Diff line
@@ -96,7 +96,7 @@ import kotlinx.coroutines.withContext
class MobileConnectionRepositoryImpl(
    override val subId: Int,
    private val context: Context,
    subscriptionModel: StateFlow<SubscriptionModel?>,
    subscriptionModel: Flow<SubscriptionModel?>,
    defaultNetworkName: NetworkNameModel,
    networkNameSeparator: String,
    connectivityManager: ConnectivityManager,
@@ -448,7 +448,7 @@ class MobileConnectionRepositoryImpl(
        fun build(
            subId: Int,
            mobileLogger: TableLogBuffer,
            subscriptionModel: StateFlow<SubscriptionModel?>,
            subscriptionModel: Flow<SubscriptionModel?>,
            defaultNetworkName: NetworkNameModel,
            networkNameSeparator: String,
        ): MobileConnectionRepository {
+4 −4
Original line number Diff line number Diff line
@@ -357,10 +357,10 @@ constructor(

    @VisibleForTesting fun getSubIdRepoCache() = subIdRepositoryCache

    private fun subscriptionModelForSubId(subId: Int): StateFlow<SubscriptionModel?> {
        return subscriptions
            .map { list -> list.firstOrNull { model -> model.subscriptionId == subId } }
            .stateIn(scope, SharingStarted.WhileSubscribed(), null)
    private fun subscriptionModelForSubId(subId: Int): Flow<SubscriptionModel?> {
        return subscriptions.map { list ->
            list.firstOrNull { model -> model.subscriptionId == subId }
        }
    }

    private fun createRepositoryForSubId(subId: Int): FullMobileConnectionRepository {