Home
last modified time | relevance | path

Searched refs:onEach (Results 1 – 25 of 107) sorted by relevance

12345

/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/pipeline/mobile/data/repository/prod/
DCarrierMergedConnectionRepositoryTest.kt35 import kotlinx.coroutines.flow.onEach
85 underTest.dataConnectionState.onEach { latestConnState = it }.launchIn(this) in inactiveWifi_isDefault()
86 val netJob = underTest.resolvedNetworkType.onEach { latestNetType = it }.launchIn(this) in inactiveWifi_isDefault()
104 underTest.dataConnectionState.onEach { latestConnState = it }.launchIn(this) in activeWifi_isDefault()
105 val netJob = underTest.resolvedNetworkType.onEach { latestNetType = it }.launchIn(this) in activeWifi_isDefault()
120 val job = underTest.primaryLevel.onEach { latest = it }.launchIn(this) in carrierMergedWifi_isValidAndFieldsComeFromWifiNetwork()
142 val job = underTest.dataActivityDirection.onEach { latest = it }.launchIn(this) in activity_comesFromWifiActivity()
181 val levelJob = underTest.primaryLevel.onEach { latestLevel = it }.launchIn(this) in carrierMergedWifi_wrongSubId_isDefault()
182 val typeJob = underTest.resolvedNetworkType.onEach { latestType = it }.launchIn(this) in carrierMergedWifi_wrongSubId_isDefault()
204 val job = underTest.primaryLevel.onEach { latest = it }.launchIn(this) in carrierMergedButNotEnabled_isDefault()
[all …]
DMobileConnectionRepositoryTest.kt104 import kotlinx.coroutines.flow.onEach
180 val job = underTest.isEmergencyOnly.onEach { latest = it }.launchIn(this) in emergencyOnly()
196 val job = underTest.isEmergencyOnly.onEach { latest = it }.launchIn(this) in emergencyOnly_toggles()
213 val job = underTest.cdmaLevel.onEach { latest = it }.launchIn(this) in cdmaLevelUpdates()
234 val job = underTest.primaryLevel.onEach { latest = it }.launchIn(this) in gsmLevelUpdates()
254 val job = underTest.isGsm.onEach { latest = it }.launchIn(this) in isGsm()
274 val job = underTest.dataConnectionState.onEach { latest = it }.launchIn(this) in dataConnectionState_connected()
289 val job = underTest.dataConnectionState.onEach { latest = it }.launchIn(this) in dataConnectionState_connecting()
304 val job = underTest.dataConnectionState.onEach { latest = it }.launchIn(this) in dataConnectionState_disconnected()
319 val job = underTest.dataConnectionState.onEach { latest = it }.launchIn(this) in dataConnectionState_disconnecting()
[all …]
DMobileConnectionTelephonySmokeTests.kt56 import kotlinx.coroutines.flow.onEach in <lambda>()
166 val job = underTest.carrierNetworkChangeActive.onEach { latest = it }.launchIn(this) in <lambda>()
195 val job = underTest.dataActivityDirection.onEach { latest = it }.launchIn(this) in <lambda>()
227 val connectionJob = underTest.dataConnectionState.onEach { latest = it }.launchIn(this) in <lambda>()
250 val job = underTest.dataEnabled.onEach { latest = it }.launchIn(this) in <lambda>()
276 val job = underTest.resolvedNetworkType.onEach { latest = it }.launchIn(this) in <lambda>()
302 val job = underTest.isEmergencyOnly.onEach { latest = it }.launchIn(this) in <lambda>()
325 val job = underTest.cdmaLevel.onEach { latest = it }.launchIn(this) in <lambda>()
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/pipeline/mobile/domain/interactor/
DMobileIconInteractorTest.kt49 import kotlinx.coroutines.flow.onEach
95 val job = underTest.signalLevelIcon.onEach { latest = it.level }.launchIn(this) in gsm_usesGsmLevel()
111 val job = underTest.signalLevelIcon.onEach { latest = it.level }.launchIn(this) in gsm_alwaysShowCdmaTrue_stillUsesGsmLevel()
124 val job = underTest.signalLevelIcon.onEach { latest = it.level }.launchIn(this) in notGsm_level_default_unknown()
139 val job = underTest.signalLevelIcon.onEach { latest = it.level }.launchIn(this) in notGsm_alwaysShowCdmaTrue_usesCdmaLevel()
155 val job = underTest.signalLevelIcon.onEach { latest = it.level }.launchIn(this) in notGsm_alwaysShowCdmaFalse_usesPrimaryLevel()
168 .onEach { latest = (it as? SignalIconModel.Cellular)?.numberOfLevels } in numberOfLevels_comesFromRepo_whenApplicable()
247 val job = underTest.networkTypeIconGroup.onEach { latest = it }.launchIn(this) in iconGroup_three_g()
261 val job = underTest.networkTypeIconGroup.onEach { latest = it }.launchIn(this) in iconGroup_updates_on_change()
278 val job = underTest.networkTypeIconGroup.onEach { latest = it }.launchIn(this) in iconGroup_5g_override_type()
[all …]
/frameworks/base/packages/SystemUI/multivalentTests/src/com/android/systemui/statusbar/pipeline/wifi/domain/interactor/
DWifiInteractorImplTest.kt33 import kotlinx.coroutines.flow.onEach
70 val job = underTest.ssid.onEach { latest = it }.launchIn(this) in ssid_unavailableNetwork_outputsNull()
84 val job = underTest.ssid.onEach { latest = it }.launchIn(this) in ssid_inactiveNetwork_outputsNull()
100 val job = underTest.ssid.onEach { latest = it }.launchIn(this) in ssid_carrierMergedNetwork_outputsNull()
121 val job = underTest.ssid.onEach { latest = it }.launchIn(this) in ssid_isPasspointAccessPoint_outputsPasspointName()
142 val job = underTest.ssid.onEach { latest = it }.launchIn(this) in ssid_isOnlineSignUpForPasspoint_outputsPasspointName()
162 val job = underTest.ssid.onEach { latest = it }.launchIn(this) in ssid_unknownSsid_outputsNull()
182 val job = underTest.ssid.onEach { latest = it }.launchIn(this) in ssid_validSsid_outputsSsid()
194 val job = underTest.isEnabled.onEach { latest = it }.launchIn(this) in isEnabled_matchesRepoIsEnabled()
215 val job = underTest.isDefault.onEach { latest = it }.launchIn(this) in isDefault_matchesRepoIsDefault()
[all …]
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/pipeline/mobile/ui/viewmodel/
DMobileIconViewModelTest.kt61 import kotlinx.coroutines.flow.onEach
163 val job = underTest.isVisible.onEach { latest = it }.launchIn(this) in isVisible_notDataCapable_alwaysFalse()
174 val job = underTest.isVisible.onEach { latest = it }.launchIn(this) in isVisible_notAirplane_notForceHidden_true()
187 val job = underTest.isVisible.onEach { latest = it }.launchIn(this) in isVisible_airplaneAndNotAllowed_false()
203 val job = underTest.isVisible.onEach { latest = it }.launchIn(this) in isVisible_airplaneButAllowed_true()
218 val job = underTest.isVisible.onEach { latest = it }.launchIn(this) in isVisible_forceHidden_false()
232 val job = underTest.isVisible.onEach { latest = it }.launchIn(this) in isVisible_respondsToUpdates()
255 val job = underTest.contentDescription.onEach { latest = it }.launchIn(this) in contentDescription_notInService_usesNoPhone()
269 val job = underTest.contentDescription.onEach { latest = it }.launchIn(this) in contentDescription_inService_usesLevel()
364 val job = underTest.networkTypeIcon.onEach { latest = it }.launchIn(this) in networkType_dataEnabled_groupIsRepresented()
[all …]
DMobileIconsViewModelTest.kt45 import kotlinx.coroutines.flow.onEach
103 val job = underTest.subscriptionIdsFlow.onEach { latest = it }.launchIn(this) in subscriptionIdsFlow_matchesInteractor()
198 underTest.firstMobileSubShowingNetworkTypeIcon.onEach { latest = it }.launchIn(this) in firstMobileSubShowingNetworkTypeIcon_noSubs_false()
212 underTest.firstMobileSubShowingNetworkTypeIcon.onEach { latest = it }.launchIn(this) in firstMobileSubShowingNetworkTypeIcon_oneSub_notShowingRat_false()
229 underTest.firstMobileSubShowingNetworkTypeIcon.onEach { latest = it }.launchIn(this) in firstMobileSubShowingNetworkTypeIcon_oneSub_showingRat_true()
246 underTest.firstMobileSubShowingNetworkTypeIcon.onEach { latest = it }.launchIn(this) in firstMobileSubShowingNetworkTypeIcon_updatesAsSubUpdates()
271 underTest.firstMobileSubShowingNetworkTypeIcon.onEach { latest = it }.launchIn(this) in firstMobileSubShowingNetworkTypeIcon_multipleSubs_lastSubNotShowingRat_false()
289 underTest.firstMobileSubShowingNetworkTypeIcon.onEach { latest = it }.launchIn(this) in firstMobileSubShowingNetworkTypeIcon_multipleSubs_lastSubShowingRat_true()
306 underTest.firstMobileSubShowingNetworkTypeIcon.onEach { latest = it }.launchIn(this) in firstMobileSubShowingNetworkTypeIcon_subListUpdates_valAlsoUpdates()
333 underTest.firstMobileSubShowingNetworkTypeIcon.onEach { latest = it }.launchIn(this) in firstMobileSubShowingNetworkTypeIcon_subListReorders_valAlsoUpdates()
/frameworks/base/packages/SystemUI/src/com/android/systemui/deviceentry/domain/interactor/
DSystemUIDeviceEntryFaceAuthInteractor.kt66 import kotlinx.coroutines.flow.onEach in <lambda>()
109 .onEach { in <lambda>()
120 .onEach { in <lambda>()
146 .onEach { in <lambda>()
165 .onEach { (fpLockedOut, currentUser) -> in <lambda>()
183 .onEach { (previous, curr) -> in <lambda>()
200 .onEach { in <lambda>()
308 .onEach { authStatusUpdate -> in <lambda>()
314 .onEach { detectionStatusUpdate -> in <lambda>()
320 .onEach { lockedOut -> listeners.forEach { it.onLockoutStateChanged(lockedOut) } } in <lambda>()
[all …]
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/pipeline/mobile/data/repository/demo/
DDemoMobileConnectionsRepositoryTest.kt45 import kotlinx.coroutines.flow.onEach in <lambda>()
118 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>()
134 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>()
150 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>()
172 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>()
194 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>()
208 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>()
222 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>()
237 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>()
252 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>()
[all …]
/frameworks/base/packages/SystemUI/src/com/android/systemui/bluetooth/qsdialog/
DBluetoothTileDialogViewModel.kt55 import kotlinx.coroutines.flow.onEach
117 .onEach { in showDialog()
137 .onEach { in showDialog()
151 .onEach { in showDialog()
168 .onEach { in showDialog()
188 .onEach { in showDialog()
196 .onEach { deviceItemActionInteractor.onClick(it, dialog) } in showDialog()
201 .onEach { in showDialog()
212 .onEach { in showDialog()
226 .onEach { bluetoothAutoOnInteractor.setEnabled(it) } in showDialog()
/frameworks/base/packages/SystemUI/src/com/android/systemui/communal/widgets/
DCommunalAppWidgetHostStartable.kt34 import kotlinx.coroutines.flow.onEach in <lambda>()
54 .onEach { (_, shouldListen) -> updateAppWidgetHostActive(shouldListen) } in <lambda>()
56 .onEach { (withPrev, widgets) -> in <lambda>()
66 .onEach { appWidgetId -> communalInteractor.deleteWidget(id = appWidgetId) } in <lambda>()
98 .onEach { widget -> communalInteractor.deleteWidget(id = widget.appWidgetId) } in <lambda>()
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/power/data/repository/
DPowerRepositoryImplTest.kt36 import kotlinx.coroutines.flow.onEach
83 val job = underTest.isInteractive.onEach {}.launchIn(this) in isInteractive_registersForBroadcasts()
95 val job = underTest.isInteractive.onEach {}.launchIn(this) in isInteractive_unregistersFromBroadcasts()
108 val job = underTest.isInteractive.onEach { value = it }.launchIn(this) in isInteractive_emitsInitialTrueValueIfScreenWasOn()
121 val job = underTest.isInteractive.onEach { value = it }.launchIn(this) in isInteractive_emitsInitialFalseValueIfScreenWasOff()
133 val job = underTest.isInteractive.onEach { value = it }.launchIn(this) in isInteractive_emitsTrueWhenTheScreenTurnsOn()
147 val job = underTest.isInteractive.onEach { value = it }.launchIn(this) in isInteractive_emitsFalseWhenTheScreenTurnsOff()
161 val job = underTest.isInteractive.onEach(values::add).launchIn(this) in isInteractive_emitsCorrectlyOverTime()
/frameworks/libs/systemui/tracinglib/core/common/src/
DFlowTracing.kt19 import kotlinx.coroutines.flow.onEach
33 return baseFlow.onEach { stateLogger.log(valueToString(it)) } in <lambda>()
39 return onEach { in traceEmissionCount()
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/pipeline/shared/data/repository/
DConnectivityRepositoryImplTest.kt46 import kotlinx.coroutines.flow.onEach
90 val job = underTest.forceHiddenSlots.onEach { latest = it }.launchIn(this) in forceHiddenSlots_initiallyGetsDefault()
103 val job = underTest.forceHiddenSlots.onEach { latest = it }.launchIn(this) in forceHiddenSlots_slotNamesAdded_flowHasSlots()
118 val job = underTest.forceHiddenSlots.onEach { latest = it }.launchIn(this) in forceHiddenSlots_wrongKey_doesNotUpdate()
144 val job = underTest.forceHiddenSlots.onEach { latest = it }.launchIn(this) in forceHiddenSlots_slotNamesAddedThenNull_flowHasDefault()
164 val job = underTest.forceHiddenSlots.onEach { latest = it }.launchIn(this) in forceHiddenSlots_someInvalidSlotNames_flowHasValidSlotsOnly()
182 val job = underTest.forceHiddenSlots.onEach { latest = it }.launchIn(this) in forceHiddenSlots_someEmptySlotNames_flowHasValidSlotsOnly()
197 val job = underTest.forceHiddenSlots.onEach { latest = it }.launchIn(this) in forceHiddenSlots_allInvalidOrEmptySlotNames_flowHasEmpty()
220 val job1 = underTest.forceHiddenSlots.onEach { latest1 = it }.launchIn(this) in forceHiddenSlots_newSubscriberGetsCurrentValue()
228 val job2 = underTest.forceHiddenSlots.onEach { latest2 = it }.launchIn(this) in forceHiddenSlots_newSubscriberGetsCurrentValue()
[all …]
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/user/data/repository/
DUserRepositoryImplTest.kt38 import kotlinx.coroutines.flow.onEach in <lambda>()
80 underTest.userSwitcherSettings.onEach { value = it }.launchIn(this) in <lambda>()
107 underTest.userSwitcherSettings.onEach { value = it }.launchIn(this) in <lambda>()
135 underTest.userInfos.onEach { userInfos = it }.launchIn(this) in <lambda>()
136 underTest.selectedUserInfo.onEach { selectedUserInfo = it }.launchIn(this) in <lambda>()
187 underTest.userInfos.onEach { userInfos = it }.launchIn(this) in <lambda>()
213 underTest.selectedUserInfo.onEach { selectedUserInfo = it }.launchIn(this) in <lambda>()
232 underTest.selectedUser.onEach { selectedUser = it }.launchIn(this) in <lambda>()
/frameworks/base/packages/SystemUI/multivalentTests/src/com/android/systemui/keyguard/data/repository/
DKeyguardRepositoryImplTest.kt48 import kotlinx.coroutines.flow.onEach in <lambda>()
173 val job = underTest.isKeyguardShowing.onEach { latest = it }.launchIn(this) in <lambda>()
202 val job = underTest.isKeyguardOccluded.onEach { latest = it }.launchIn(this) in <lambda>()
270 val job = underTest.linearDozeAmount.onEach(values::add).launchIn(this) in <lambda>()
315 val job = underTest.isKeyguardGoingAway.onEach { latest = it }.launchIn(this) in <lambda>()
353 val job = underTest.isDreamingWithOverlay.onEach { latest = it }.launchIn(this) in <lambda>()
382 val job = underTest.dozeTransitionModel.onEach(values::add).launchIn(this) in <lambda>()
449 val job = underTest.fingerprintSensorLocation.onEach(values::add).launchIn(this) in <lambda>()
462 .onEach { in <lambda>()
478 val job = underTest.faceSensorLocation.onEach(values::add).launchIn(this) in <lambda>()
[all …]
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/pipeline/airplane/ui/viewmodel/
DAirplaneModeViewModelImplTest.kt32 import kotlinx.coroutines.flow.onEach
80 val job = underTest.isAirplaneModeIconVisible.onEach { latest = it }.launchIn(this) in isAirplaneModeIconVisible_notAirplaneMode_outputsFalse()
94 val job = underTest.isAirplaneModeIconVisible.onEach { latest = it }.launchIn(this) in isAirplaneModeIconVisible_forceHidden_outputsFalse()
108 val job = underTest.isAirplaneModeIconVisible.onEach { latest = it }.launchIn(this) in isAirplaneModeIconVisible_isAirplaneModeAndNotForceHidden_outputsTrue()
/frameworks/base/packages/SystemUI/multivalentTests/src/com/android/systemui/volume/domain/interactor/
DAudioModeInteractorTest.kt28 import kotlinx.coroutines.flow.onEach
50 underTest.isOngoingCall.onEach { isOngoingCall = it }.launchIn(backgroundScope) in ongoingCallModes_isOnGoingCall()
64 underTest.isOngoingCall.onEach { isOngoingCall = it }.launchIn(backgroundScope) in notOngoingCallModes_isNotOnGoingCall()
/frameworks/base/packages/SettingsLib/tests/integ/src/com/android/settingslib/volume/data/repository/
DAudioRepositoryTest.kt33 import kotlinx.coroutines.flow.onEach
119 underTest.mode.onEach { modes.add(it) }.launchIn(backgroundScope) in audioModeChanges_repositoryEmits()
133 underTest.ringerMode.onEach { modes.add(it) }.launchIn(backgroundScope) in ringerModeChanges_repositoryEmits()
152 underTest.communicationDevice.onEach { device = it }.launchIn(backgroundScope) in communicationDeviceChanges_repositoryEmits()
169 .onEach { streamModel = it } in adjustingVolume_changesTheStream()
198 .onEach { streamModel = it } in muteStream_mutesTheStream()
228 .onEach { streamModel = it } in unmuteStream_unmutesTheStream()
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/pipeline/airplane/domain/interactor/
DAirplaneModeInteractorTest.kt32 import kotlinx.coroutines.flow.onEach
58 underTest.isAirplaneMode.onEach { latest = it }.launchIn(backgroundScope) in <lambda>()
78 underTest.isForceHidden.onEach { latest = it }.launchIn(backgroundScope) in <lambda>()
89 underTest.isForceHidden.onEach { latest = it }.launchIn(backgroundScope) in <lambda>()
/frameworks/base/packages/SystemUI/multivalentTests/src/com/android/systemui/keyguard/data/quickaffordance/
DQrCodeScannerKeyguardQuickAffordanceConfigTest.kt31 import kotlinx.coroutines.flow.onEach
63 val job = underTest.lockScreenState.onEach { latest = it }.launchIn(this) in <lambda>()
82 val job = underTest.lockScreenState.onEach { latest = it }.launchIn(this) in <lambda>()
98 val job = underTest.lockScreenState.onEach { latest = it }.launchIn(this) in <lambda>()
114 val job = underTest.lockScreenState.onEach { latest = it }.launchIn(this) in <lambda>()
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/keyguard/data/repository/
DKeyguardTransitionRepositoryTest.kt50 import kotlinx.coroutines.flow.onEach in <lambda>()
90 val job = underTest.transition(AOD, LOCKSCREEN).onEach { steps.add(it) }.launchIn(this) in <lambda>()
106 val job = underTest.transition(AOD, LOCKSCREEN).onEach { steps.add(it) }.launchIn(this) in <lambda>()
114 val job2 = underTest.transition(LOCKSCREEN, AOD).onEach { steps.add(it) }.launchIn(this) in <lambda>()
141 val job = underTest.transition(AOD, LOCKSCREEN).onEach { steps.add(it) }.launchIn(this) in <lambda>()
149 val job2 = underTest.transition(LOCKSCREEN, AOD).onEach { steps.add(it) }.launchIn(this) in <lambda>()
176 val job = underTest.transition(AOD, LOCKSCREEN).onEach { steps.add(it) }.launchIn(this) in <lambda>()
184 val job2 = underTest.transition(LOCKSCREEN, AOD).onEach { steps.add(it) }.launchIn(this) in <lambda>()
211 val job = underTest.transition(AOD, LOCKSCREEN).onEach { steps.add(it) }.launchIn(this) in <lambda>()
247 .onEach { steps.add(it) } in <lambda>()
[all …]
/frameworks/base/packages/SystemUI/src/com/android/systemui/keyguard/domain/interactor/
DDeviceEntrySideFpsOverlayInteractor.kt43 import kotlinx.coroutines.flow.onEach in <lambda>()
101 .onEach { Log.d(TAG, "showIndicatorForPrimaryBouncer updated: $it") } in <lambda>()
105 alternateBouncerInteractor.isVisible.onEach { in <lambda>()
120 .onEach { Log.d(TAG, "showIndicatorForDeviceEntry updated: $it") } in <lambda>()
/frameworks/base/packages/SettingsLib/tests/integ/src/com/android/settingslib/volume/shared/
DAudioManagerEventsReceiverTest.kt30 import kotlinx.coroutines.flow.onEach
70 underTest.events.onEach { events.add(it) }.launchIn(backgroundScope) in validIntent_translatedToEvent()
108 underTest.events.onEach { events.add(it) }.launchIn(backgroundScope) in streamAudioManagerEvent_withoutAudioStream_areSkipped()
123 underTest.events.onEach { events.add(it) }.launchIn(backgroundScope) in invalidIntents_areSkipped()
/frameworks/base/packages/SystemUI/src/com/android/systemui/biometrics/domain/interactor/
DLogContextInteractor.kt37 import kotlinx.coroutines.flow.onEach in <lambda>()
135 .onEach { state -> listener.onFoldChanged(state) } in addBiometricContextListener()
141 .onEach { state -> listener.onDisplayStateChanged(state) } in addBiometricContextListener()
147 .onEach { state -> listener.onHardwareIgnoreTouchesChanged(state) } in addBiometricContextListener()

12345