Home
last modified time | relevance | path

Searched refs:flow (Results 1 – 25 of 455) sorted by relevance

12345678910>>...19

/packages/apps/Settings/src/com/android/settings/biometrics/fingerprint2/ui/enrollment/viewmodel/
DFingerprintNavigationViewModel.kt33 import kotlinx.coroutines.flow.Flow in <lambda>()
34 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
35 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
36 import kotlinx.coroutines.flow.StateFlow in <lambda>()
37 import kotlinx.coroutines.flow.asStateFlow in <lambda>()
38 import kotlinx.coroutines.flow.combine in <lambda>()
39 import kotlinx.coroutines.flow.combineTransform in <lambda>()
40 import kotlinx.coroutines.flow.filterNotNull in <lambda>()
41 import kotlinx.coroutines.flow.stateIn in <lambda>()
42 import kotlinx.coroutines.flow.update in <lambda>()
[all …]
DFingerprintEnrollViewModel.kt33 import kotlinx.coroutines.flow.Flow in <lambda>()
34 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
35 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
36 import kotlinx.coroutines.flow.combine in <lambda>()
37 import kotlinx.coroutines.flow.filterNotNull in <lambda>()
38 import kotlinx.coroutines.flow.map in <lambda>()
39 import kotlinx.coroutines.flow.shareIn in <lambda>()
40 import kotlinx.coroutines.flow.transformLatest in <lambda>()
41 import kotlinx.coroutines.flow.update in <lambda>()
/packages/providers/MediaProvider/photopicker/tests/src/com/android/photopicker/core/selection/
DGrantsAwareSelectionTest.kt27 import kotlinx.coroutines.flow.first
28 import kotlinx.coroutines.flow.toList
69 .that(selection.flow.first()) in <lambda>()
88 val flow = selection.flow.first() in testSelectionIsInitialized() constant
96 .that(flow) in testSelectionIsInitialized()
98 assertWithMessage("Emitted flow has an unexpected size").that(flow).hasSize(10) in testSelectionIsInitialized()
157 backgroundScope.launch { selection.flow.toList(emissions) } in <lambda>()
170 val flow = emissions.last() in <lambda>() constant
172 .that(flow) in <lambda>()
174 assertWithMessage("Emitted flow has an unexpected size").that(flow).hasSize(1) in <lambda>()
[all …]
DSelectionImplTest.kt26 import kotlinx.coroutines.flow.first
27 import kotlinx.coroutines.flow.toList
65 .that(selection.flow.first()) in <lambda>()
84 val flow = selection.flow.first() in testSelectionIsInitialized() constant
92 .that(flow) in testSelectionIsInitialized()
94 assertWithMessage("Emitted flow has an unexpected size").that(flow).hasSize(10) in testSelectionIsInitialized()
153 backgroundScope.launch { selection.flow.toList(emissions) } in <lambda>()
166 val flow = emissions.last() in <lambda>() constant
168 .that(flow) in <lambda>()
170 assertWithMessage("Emitted flow has an unexpected size").that(flow).hasSize(1) in <lambda>()
[all …]
/packages/modules/IntentResolver/java/src/com/android/intentresolver/contentpreview/
DJavaFlowHelper.kt24 import kotlinx.coroutines.flow.Flow in <lambda>()
25 import kotlinx.coroutines.flow.filter in <lambda>()
26 import kotlinx.coroutines.flow.map in <lambda>()
27 import kotlinx.coroutines.flow.toList in <lambda>()
31 flow: Flow<FileInfo>, in <lambda>()
35 flow in <lambda>()
47 flow: Flow<T>, in collectToList()
50 clientScope.launch { callback.accept(flow.toList()) } in collectToList()
/packages/apps/ThemePicker/src/com/android/customization/picker/grid/domain/interactor/
DGridInteractor.kt27 import kotlinx.coroutines.flow.Flow in <lambda>()
28 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
29 import kotlinx.coroutines.flow.emptyFlow in <lambda>()
30 import kotlinx.coroutines.flow.flatMapLatest in <lambda>()
31 import kotlinx.coroutines.flow.flow in <lambda>()
32 import kotlinx.coroutines.flow.map in <lambda>()
33 import kotlinx.coroutines.flow.onStart in <lambda>()
34 import kotlinx.coroutines.flow.shareIn in <lambda>()
42 flow { emit(repository.isAvailable()) } in <lambda>()
/packages/apps/Settings/src/com/android/settings/biometrics/fingerprint2/ui/settings/viewmodel/
DFingerprintSettingsViewModel.kt29 import kotlinx.coroutines.flow.Flow in <lambda>()
30 import kotlinx.coroutines.flow.MutableSharedFlow in <lambda>()
31 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
32 import kotlinx.coroutines.flow.asStateFlow in <lambda>()
33 import kotlinx.coroutines.flow.combine in <lambda>()
34 import kotlinx.coroutines.flow.combineTransform in <lambda>()
35 import kotlinx.coroutines.flow.distinctUntilChanged in <lambda>()
36 import kotlinx.coroutines.flow.filterNotNull in <lambda>()
37 import kotlinx.coroutines.flow.first in <lambda>()
38 import kotlinx.coroutines.flow.flowOn in <lambda>()
[all …]
/packages/apps/Launcher3/quickstep/src/com/android/quickstep/recents/data/
DTasksRepository.kt26 import kotlinx.coroutines.flow.Flow in <lambda>()
27 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
28 import kotlinx.coroutines.flow.combine in <lambda>()
29 import kotlinx.coroutines.flow.distinctUntilChanged in <lambda>()
30 import kotlinx.coroutines.flow.flatMapLatest in <lambda>()
31 import kotlinx.coroutines.flow.flow in <lambda>()
32 import kotlinx.coroutines.flow.flowOf in <lambda>()
33 import kotlinx.coroutines.flow.map in <lambda>()
72 flow { in <lambda>()
/packages/modules/Bluetooth/android/pandora/server/src/
DLeAudio.kt34 import kotlinx.coroutines.flow.Flow
35 import kotlinx.coroutines.flow.SharingStarted
36 import kotlinx.coroutines.flow.filter
37 import kotlinx.coroutines.flow.first
38 import kotlinx.coroutines.flow.map
39 import kotlinx.coroutines.flow.shareIn
49 private val flow: Flow<Intent> constant in com.android.pandora.LeAudio
63 flow = intentFlow(context, intentFilter, scope).shareIn(scope, SharingStarted.Eagerly)
79 flow in open()
DA2dpSink.kt34 import kotlinx.coroutines.flow.Flow
35 import kotlinx.coroutines.flow.SharingStarted
36 import kotlinx.coroutines.flow.filter
37 import kotlinx.coroutines.flow.first
38 import kotlinx.coroutines.flow.map
39 import kotlinx.coroutines.flow.shareIn
48 private val flow: Flow<Intent> constant in com.android.pandora.A2dpSink
60 flow = intentFlow(context, intentFilter, scope).shareIn(scope, SharingStarted.Eagerly)
78 flow in waitSink()
112 flow in close()
/packages/apps/Settings/src/com/android/settings/biometrics/fingerprint2/ui/enrollment/modules/enrolling/rfps/ui/viewmodel/
DRFPSViewModel.kt35 import kotlinx.coroutines.flow.Flow in <lambda>()
36 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
37 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
38 import kotlinx.coroutines.flow.asStateFlow in <lambda>()
39 import kotlinx.coroutines.flow.combine in <lambda>()
40 import kotlinx.coroutines.flow.filterIsInstance in <lambda>()
41 import kotlinx.coroutines.flow.filterNotNull in <lambda>()
42 import kotlinx.coroutines.flow.map in <lambda>()
43 import kotlinx.coroutines.flow.shareIn in <lambda>()
44 import kotlinx.coroutines.flow.transform in <lambda>()
[all …]
DRFPSIconTouchViewModel.kt24 import kotlinx.coroutines.flow.Flow in <lambda>()
25 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
26 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
27 import kotlinx.coroutines.flow.shareIn in <lambda>()
28 import kotlinx.coroutines.flow.transform in <lambda>()
29 import kotlinx.coroutines.flow.update in <lambda>()
/packages/apps/Settings/src/com/android/settings/biometrics/fingerprint2/ui/enrollment/modules/enrolling/udfps/ui/viewmodel/
DUdfpsLastStepViewModel.kt30 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
31 import kotlinx.coroutines.flow.distinctUntilChanged in <lambda>()
32 import kotlinx.coroutines.flow.filter in <lambda>()
33 import kotlinx.coroutines.flow.filterIsInstance in <lambda>()
34 import kotlinx.coroutines.flow.filterNotNull in <lambda>()
35 import kotlinx.coroutines.flow.take in <lambda>()
36 import kotlinx.coroutines.flow.toList in <lambda>()
37 import kotlinx.coroutines.flow.transform in <lambda>()
38 import kotlinx.coroutines.flow.update in <lambda>()
/packages/apps/Settings/src/com/android/settings/deviceinfo/simstatus/
DSimStatusDialogRepository.kt32 import kotlinx.coroutines.flow.Flow in <lambda>()
33 import kotlinx.coroutines.flow.combine in <lambda>()
34 import kotlinx.coroutines.flow.conflate in <lambda>()
35 import kotlinx.coroutines.flow.flatMapLatest in <lambda>()
36 import kotlinx.coroutines.flow.flow in <lambda>()
37 import kotlinx.coroutines.flow.flowOf in <lambda>()
38 import kotlinx.coroutines.flow.flowOn in <lambda>()
101 private fun showUpFlow(subId: Int) = flow { in <lambda>()
/packages/apps/Settings/src/com/android/settings/network/telephony/
DCallStateRepository.kt25 import kotlinx.coroutines.flow.Flow in <lambda>()
26 import kotlinx.coroutines.flow.combine in <lambda>()
27 import kotlinx.coroutines.flow.conflate in <lambda>()
28 import kotlinx.coroutines.flow.flatMapLatest in <lambda>()
29 import kotlinx.coroutines.flow.flowOf in <lambda>()
30 import kotlinx.coroutines.flow.flowOn in <lambda>()
31 import kotlinx.coroutines.flow.onEach in <lambda>()
DSubscriptionRepository.kt29 import kotlinx.coroutines.flow.Flow in <lambda>()
30 import kotlinx.coroutines.flow.callbackFlow in <lambda>()
31 import kotlinx.coroutines.flow.conflate in <lambda>()
32 import kotlinx.coroutines.flow.filterNot in <lambda>()
33 import kotlinx.coroutines.flow.flowOf in <lambda>()
34 import kotlinx.coroutines.flow.flowOn in <lambda>()
35 import kotlinx.coroutines.flow.map in <lambda>()
36 import kotlinx.coroutines.flow.onEach in <lambda>()
/packages/apps/Settings/tests/spa_unit/src/com/android/settings/network/telephony/
DTelephonyRepositoryTest.kt27 import kotlinx.coroutines.flow.flowOf
58 val flow = repository.isMobileDataPolicyEnabledFlow( in <lambda>() constant
63 assertThat(flow.firstWithTimeoutOrNull()).isFalse() in <lambda>()
74 val flow = repository.isMobileDataPolicyEnabledFlow( in <lambda>() constant
79 assertThat(flow.firstWithTimeoutOrNull()).isTrue() in <lambda>()
118 val flow = context.telephonyCallbackFlow<Unit>(SUB_ID) { in <lambda>() constant
122 flow.firstWithTimeoutOrNull() in <lambda>()
129 val flow = context.telephonyCallbackFlow<Unit>(SUB_ID) { in <lambda>() constant
133 flow.firstWithTimeoutOrNull() in <lambda>()
/packages/apps/Settings/src/com/android/settings/biometrics/fingerprint2/domain/interactor/
DDisplayDensityInteractor.kt22 import kotlinx.coroutines.flow.Flow
23 import kotlinx.coroutines.flow.MutableStateFlow
24 import kotlinx.coroutines.flow.SharingStarted
25 import kotlinx.coroutines.flow.asStateFlow
26 import kotlinx.coroutines.flow.flowOf
27 import kotlinx.coroutines.flow.shareIn
28 import kotlinx.coroutines.flow.update
/packages/apps/Settings/src/com/android/settings/network/
DTetheredRepository.kt32 import kotlinx.coroutines.flow.Flow in <lambda>()
33 import kotlinx.coroutines.flow.callbackFlow in <lambda>()
34 import kotlinx.coroutines.flow.combine in <lambda>()
35 import kotlinx.coroutines.flow.conflate in <lambda>()
36 import kotlinx.coroutines.flow.flatMapLatest in <lambda>()
37 import kotlinx.coroutines.flow.flowOf in <lambda>()
38 import kotlinx.coroutines.flow.flowOn in <lambda>()
39 import kotlinx.coroutines.flow.merge in <lambda>()
/packages/apps/ThemePicker/src/com/android/customization/picker/clock/data/repository/
DClockPickerRepositoryImpl.kt32 import kotlinx.coroutines.flow.Flow in <lambda>()
33 import kotlinx.coroutines.flow.SharedFlow in <lambda>()
34 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
35 import kotlinx.coroutines.flow.callbackFlow in <lambda>()
36 import kotlinx.coroutines.flow.distinctUntilChanged in <lambda>()
37 import kotlinx.coroutines.flow.flowOn in <lambda>()
38 import kotlinx.coroutines.flow.map in <lambda>()
39 import kotlinx.coroutines.flow.mapLatest in <lambda>()
40 import kotlinx.coroutines.flow.mapNotNull in <lambda>()
41 import kotlinx.coroutines.flow.shareIn in <lambda>()
/packages/apps/ThemePicker/src/com/android/customization/picker/clock/ui/viewmodel/
DClockCarouselViewModel.kt32 import kotlinx.coroutines.flow.Flow in <lambda>()
33 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
34 import kotlinx.coroutines.flow.StateFlow in <lambda>()
35 import kotlinx.coroutines.flow.flatMapLatest in <lambda>()
36 import kotlinx.coroutines.flow.flowOn in <lambda>()
37 import kotlinx.coroutines.flow.map in <lambda>()
38 import kotlinx.coroutines.flow.mapLatest in <lambda>()
39 import kotlinx.coroutines.flow.mapNotNull in <lambda>()
40 import kotlinx.coroutines.flow.stateIn in <lambda>()
/packages/apps/Settings/tests/shared/src/com/android/settings/testutils2/
DFakeFingerprintManagerInteractor.kt33 import kotlinx.coroutines.flow.Flow
34 import kotlinx.coroutines.flow.flow
35 import kotlinx.coroutines.flow.flowOf
67 override val enrolledFingerprints: Flow<List<FingerprintData>> = flow { in <lambda>()
71 override val canEnrollFingerprints: Flow<Boolean> = flow { in <lambda>()
75 override val sensorPropertiesInternal: Flow<FingerprintSensor?> = flow { emit(sensorProp) } in <lambda>()
77 override val maxEnrollableFingerprints: Flow<Int> = flow { emit(enrollableFingerprints) } in <lambda>()
/packages/providers/MediaProvider/photopicker/tests/src/com/android/photopicker/core/configuration/
DTestPhotopickerConfiguration.kt22 import kotlinx.coroutines.flow.SharingStarted
23 import kotlinx.coroutines.flow.StateFlow
24 import kotlinx.coroutines.flow.flow
25 import kotlinx.coroutines.flow.stateIn
87 return flow { emit(defaultConfiguration) } in provideTestConfigurationFlow()
/packages/apps/Car/Launcher/libs/appgrid/lib/src/com/android/car/carlauncher/datasources/
DAppOrderDataSource.kt26 import kotlinx.coroutines.flow.Flow in <lambda>()
27 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
28 import kotlinx.coroutines.flow.emitAll in <lambda>()
29 import kotlinx.coroutines.flow.flow in <lambda>()
30 import kotlinx.coroutines.flow.flowOn in <lambda>()
31 import kotlinx.coroutines.flow.map in <lambda>()
134 override fun getSavedAppOrder(): Flow<List<AppOrderInfo>> = flow { in getSavedAppOrder()
/packages/providers/MediaProvider/photopicker/src/com/android/photopicker/core/events/
DEvents.kt25 import kotlinx.coroutines.flow.SharedFlow in <lambda>()
26 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
27 import kotlinx.coroutines.flow.StateFlow in <lambda>()
28 import kotlinx.coroutines.flow.receiveAsFlow in <lambda>()
29 import kotlinx.coroutines.flow.shareIn in <lambda>()
73 val flow: SharedFlow<Event> = in <lambda>() constant in com.android.photopicker.core.events.Events

12345678910>>...19