| /frameworks/base/packages/SystemUI/tests/src/com/android/systemui/shared/condition/ |
| D | ConditionExtensionsTest.kt | 8 import kotlinx.coroutines.flow.MutableSharedFlow
9 import kotlinx.coroutines.flow.MutableStateFlow
10 import kotlinx.coroutines.flow.emptyFlow
11 import kotlinx.coroutines.flow.flowOf
34 val flow = flowOf(true) in flowInitiallyTrue() constant
35 val condition = flow.toCondition(scope = this, Condition.START_EAGERLY) in flowInitiallyTrue()
49 val flow = flowOf(false) in flowInitiallyFalse() constant
50 val condition = flow.toCondition(scope = this, Condition.START_EAGERLY) in flowInitiallyFalse()
64 val flow = emptyFlow<Boolean>() in emptyFlowWithNoInitialValue() constant
65 val condition = flow.toCondition(scope = this, Condition.START_EAGERLY) in emptyFlowWithNoInitialValue()
[all …]
|
| /frameworks/base/packages/SystemUI/tests/src/com/android/systemui/log/table/ |
| D | LogDiffsForTableTest.kt | 28 import kotlinx.coroutines.flow.MutableStateFlow
29 import kotlinx.coroutines.flow.collect
30 import kotlinx.coroutines.flow.flow
31 import kotlinx.coroutines.flow.flowOf
67 val flow = flowOf(true, true, false) in boolean_doesNotLogWhenNotCollected() constant
69 flow.logDiffsForTable( in boolean_doesNotLogWhenNotCollected()
85 val flow = flowOf(true, true, false) in boolean_logsInitialWhenCollected() constant
88 flow.logDiffsForTable( in boolean_logsInitialWhenCollected()
116 val flow = flow { in boolean_logsUpdates() constant
124 flow.logDiffsForTable( in boolean_logsUpdates()
[all …]
|
| /frameworks/base/packages/SettingsLib/src/com/android/settingslib/volume/data/repository/ |
| D | MediaControllerRepository.kt | 29 import kotlinx.coroutines.flow.SharingStarted
30 import kotlinx.coroutines.flow.StateFlow
31 import kotlinx.coroutines.flow.emptyFlow
32 import kotlinx.coroutines.flow.filterIsInstance
33 import kotlinx.coroutines.flow.filterNotNull
34 import kotlinx.coroutines.flow.flowOn
35 import kotlinx.coroutines.flow.map
36 import kotlinx.coroutines.flow.merge
37 import kotlinx.coroutines.flow.onStart
38 import kotlinx.coroutines.flow.stateIn
|
| D | LocalMediaRepository.kt | 25 import kotlinx.coroutines.flow.Flow
26 import kotlinx.coroutines.flow.SharingStarted
27 import kotlinx.coroutines.flow.StateFlow
28 import kotlinx.coroutines.flow.callbackFlow
29 import kotlinx.coroutines.flow.filterIsInstance
30 import kotlinx.coroutines.flow.map
31 import kotlinx.coroutines.flow.merge
32 import kotlinx.coroutines.flow.onStart
33 import kotlinx.coroutines.flow.shareIn
34 import kotlinx.coroutines.flow.stateIn
|
| /frameworks/base/packages/SystemUI/utils/src/com/android/systemui/utils/coroutines/flow/ |
| D | FlowConflated.kt | 19 package com.android.systemui.utils.coroutines.flow
25 import kotlinx.coroutines.flow.Flow
26 import kotlinx.coroutines.flow.buffer
27 import kotlinx.coroutines.flow.callbackFlow
28 import kotlinx.coroutines.flow.channelFlow
29 import kotlinx.coroutines.flow.conflate
30 import kotlinx.coroutines.flow.flowOn
31 import kotlinx.coroutines.flow.produceIn
|
| D | LatestConflated.kt | 19 package com.android.systemui.utils.coroutines.flow
23 import kotlinx.coroutines.flow.Flow
24 import kotlinx.coroutines.flow.FlowCollector
25 import kotlinx.coroutines.flow.conflate
26 import kotlinx.coroutines.flow.flatMapLatest
27 import kotlinx.coroutines.flow.mapLatest
28 import kotlinx.coroutines.flow.transformLatest
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/communal/domain/interactor/ |
| D | CommunalTutorialInteractor.kt | 30 import kotlinx.coroutines.flow.Flow in <lambda>()
31 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
32 import kotlinx.coroutines.flow.StateFlow in <lambda>()
33 import kotlinx.coroutines.flow.combine in <lambda>()
34 import kotlinx.coroutines.flow.distinctUntilChanged in <lambda>()
35 import kotlinx.coroutines.flow.emptyFlow in <lambda>()
36 import kotlinx.coroutines.flow.filterNotNull in <lambda>()
37 import kotlinx.coroutines.flow.flatMapLatest in <lambda>()
38 import kotlinx.coroutines.flow.flowOf in <lambda>()
39 import kotlinx.coroutines.flow.map in <lambda>()
[all …]
|
| D | CommunalSceneInteractor.kt | 31 import kotlinx.coroutines.flow.Flow in <lambda>()
32 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
33 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
34 import kotlinx.coroutines.flow.StateFlow in <lambda>()
35 import kotlinx.coroutines.flow.asStateFlow in <lambda>()
36 import kotlinx.coroutines.flow.distinctUntilChanged in <lambda>()
37 import kotlinx.coroutines.flow.flatMapLatest in <lambda>()
38 import kotlinx.coroutines.flow.flowOf in <lambda>()
39 import kotlinx.coroutines.flow.map in <lambda>()
40 import kotlinx.coroutines.flow.stateIn in <lambda>()
|
| /frameworks/base/packages/SettingsLib/SpaPrivileged/src/com/android/settingslib/spaprivileged/model/app/ |
| D | AppListViewModel.kt | 33 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.flatMapLatest in <lambda>()
39 import kotlinx.coroutines.flow.flowOf in <lambda>()
40 import kotlinx.coroutines.flow.launchIn in <lambda>()
41 import kotlinx.coroutines.flow.map in <lambda>()
42 import kotlinx.coroutines.flow.shareIn in <lambda>()
[all …]
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/util/kotlin/ |
| D | Flow.kt | 28 import kotlinx.coroutines.flow.Flow in <lambda>()
29 import kotlinx.coroutines.flow.MutableSharedFlow in <lambda>()
30 import kotlinx.coroutines.flow.channelFlow in <lambda>()
31 import kotlinx.coroutines.flow.distinctUntilChanged in <lambda>()
32 import kotlinx.coroutines.flow.filter in <lambda>()
33 import kotlinx.coroutines.flow.flow in <lambda>()
34 import kotlinx.coroutines.flow.map in <lambda>()
35 import kotlinx.coroutines.flow.onStart in <lambda>()
45 fun <T, R> Flow<T>.pairwiseBy(transform: suspend (old: T, new: T) -> R): Flow<R> = flow { in <lambda>()
79 ): Flow<R> = flow { in pairwiseBy()
[all …]
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/wallpapers/data/repository/ |
| D | WallpaperRepository.kt | 31 import com.android.systemui.utils.coroutines.flow.mapLatestConflated in <lambda>()
35 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.StateFlow in <lambda>()
39 import kotlinx.coroutines.flow.asStateFlow in <lambda>()
40 import kotlinx.coroutines.flow.combine in <lambda>()
41 import kotlinx.coroutines.flow.filter in <lambda>()
42 import kotlinx.coroutines.flow.map in <lambda>()
43 import kotlinx.coroutines.flow.onStart in <lambda>()
[all …]
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/qs/tiles/base/viewmodel/ |
| D | QSTileViewModelImpl.kt | 43 import kotlinx.coroutines.flow.Flow in <lambda>()
44 import kotlinx.coroutines.flow.MutableSharedFlow in <lambda>()
45 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
46 import kotlinx.coroutines.flow.SharedFlow in <lambda>()
47 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
48 import kotlinx.coroutines.flow.StateFlow in <lambda>()
49 import kotlinx.coroutines.flow.cancellable in <lambda>()
50 import kotlinx.coroutines.flow.combine in <lambda>()
51 import kotlinx.coroutines.flow.distinctUntilChanged in <lambda>()
52 import kotlinx.coroutines.flow.filter in <lambda>()
[all …]
|
| /frameworks/base/packages/SettingsLib/Spa/spa/src/com/android/settingslib/spa/framework/compose/ |
| D | OverridableFlow.kt | 20 import kotlinx.coroutines.flow.Flow
21 import kotlinx.coroutines.flow.merge
22 import kotlinx.coroutines.flow.receiveAsFlow
27 class OverridableFlow<T>(flow: Flow<T>) {
30 val flow = merge(overrideChannel.receiveAsFlow(), flow) constant
|
| /frameworks/base/packages/SystemUI/tests/src/com/android/systemui/util/kotlin/ |
| D | FlowUtilTests.kt | 28 import kotlinx.coroutines.flow.Flow in <lambda>()
29 import kotlinx.coroutines.flow.MutableSharedFlow in <lambda>()
30 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
31 import kotlinx.coroutines.flow.asFlow in <lambda>()
32 import kotlinx.coroutines.flow.emptyFlow in <lambda>()
33 import kotlinx.coroutines.flow.filterIsInstance in <lambda>()
34 import kotlinx.coroutines.flow.flow in <lambda>()
35 import kotlinx.coroutines.flow.flowOf in <lambda>()
36 import kotlinx.coroutines.flow.merge in <lambda>()
37 import kotlinx.coroutines.flow.takeWhile in <lambda>()
[all …]
|
| /frameworks/base/packages/SettingsLib/Spa/tests/src/com/android/settingslib/spa/lifecycle/ |
| D | FlowExtTest.kt | 24 import kotlinx.coroutines.flow.MutableStateFlow
25 import kotlinx.coroutines.flow.flowOf
37 val flow = flowOf(TEXT) in collectAsCallbackWithLifecycle() constant
40 val callback = flow.collectAsCallbackWithLifecycle() in collectAsCallbackWithLifecycle()
49 val flow = MutableStateFlow(TEXT) in collectAsCallbackWithLifecycle_changed() constant
52 val callback = flow.collectAsCallbackWithLifecycle() in collectAsCallbackWithLifecycle_changed()
55 flow.value = NEW_TEXT in collectAsCallbackWithLifecycle_changed()
|
| /frameworks/base/packages/SettingsLib/src/com/android/settingslib/statusbar/notification/data/repository/ |
| D | NotificationsSoundPolicyRepository.kt | 28 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
29 import kotlinx.coroutines.flow.StateFlow in <lambda>()
30 import kotlinx.coroutines.flow.callbackFlow in <lambda>()
31 import kotlinx.coroutines.flow.filter in <lambda>()
32 import kotlinx.coroutines.flow.flowOn in <lambda>()
33 import kotlinx.coroutines.flow.map in <lambda>()
34 import kotlinx.coroutines.flow.onStart in <lambda>()
35 import kotlinx.coroutines.flow.shareIn in <lambda>()
36 import kotlinx.coroutines.flow.stateIn in <lambda>()
|
| /frameworks/base/packages/SettingsLib/Spa/tests/src/com/android/settingslib/spa/framework/compose/ |
| D | OverridableFlowTest.kt | 21 import kotlinx.coroutines.flow.Flow
22 import kotlinx.coroutines.flow.flowOf
23 import kotlinx.coroutines.flow.toList
38 val values = collectValues(overridableFlow.flow) in <lambda>()
50 val values = collectValues(overridableFlow.flow) in <lambda>()
55 private suspend fun <T> collectValues(flow: Flow<T>): List<T> = withTimeout(500) { in <lambda>()
57 flow.toList(flowValues) in <lambda>()
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/volume/panel/component/mediaoutput/domain/interactor/ |
| D | MediaOutputComponentInteractor.kt | 31 import kotlinx.coroutines.flow.Flow in <lambda>()
32 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
33 import kotlinx.coroutines.flow.StateFlow in <lambda>()
34 import kotlinx.coroutines.flow.combine in <lambda>()
35 import kotlinx.coroutines.flow.filter in <lambda>()
36 import kotlinx.coroutines.flow.flatMapLatest in <lambda>()
37 import kotlinx.coroutines.flow.flowOf in <lambda>()
38 import kotlinx.coroutines.flow.map in <lambda>()
39 import kotlinx.coroutines.flow.mapNotNull in <lambda>()
40 import kotlinx.coroutines.flow.stateIn in <lambda>()
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/keyguard/ui/viewmodel/ |
| D | AlternateBouncerMessageAreaViewModel.kt | 30 import kotlinx.coroutines.flow.Flow in <lambda>()
31 import kotlinx.coroutines.flow.filter in <lambda>()
32 import kotlinx.coroutines.flow.filterIsInstance in <lambda>()
33 import kotlinx.coroutines.flow.filterNot in <lambda>()
34 import kotlinx.coroutines.flow.flatMapLatest in <lambda>()
35 import kotlinx.coroutines.flow.flowOf in <lambda>()
36 import kotlinx.coroutines.flow.map in <lambda>()
37 import kotlinx.coroutines.flow.merge in <lambda>()
38 import kotlinx.coroutines.flow.onStart in <lambda>()
|
| /frameworks/base/packages/SettingsLib/src/com/android/settingslib/view/accessibility/data/repository/ |
| D | CaptioningRepository.kt | 24 import kotlinx.coroutines.flow.SharedFlow
25 import kotlinx.coroutines.flow.SharingStarted
26 import kotlinx.coroutines.flow.StateFlow
27 import kotlinx.coroutines.flow.callbackFlow
28 import kotlinx.coroutines.flow.filterIsInstance
29 import kotlinx.coroutines.flow.map
30 import kotlinx.coroutines.flow.onStart
31 import kotlinx.coroutines.flow.shareIn
32 import kotlinx.coroutines.flow.stateIn
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/keyboard/backlight/ui/viewmodel/ |
| D | BacklightDialogViewModel.kt | 26 import kotlinx.coroutines.flow.Flow
27 import kotlinx.coroutines.flow.filterNotNull
28 import kotlinx.coroutines.flow.flatMapLatest
29 import kotlinx.coroutines.flow.flow
30 import kotlinx.coroutines.flow.map
61 flow { in timeout()
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/qs/tiles/impl/custom/domain/interactor/ |
| D | CustomTileDataInteractor.kt | 35 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.combine in <lambda>()
39 import kotlinx.coroutines.flow.first in <lambda>()
40 import kotlinx.coroutines.flow.flatMapLatest in <lambda>()
41 import kotlinx.coroutines.flow.launchIn in <lambda>()
42 import kotlinx.coroutines.flow.map in <lambda>()
43 import kotlinx.coroutines.flow.mapNotNull in <lambda>()
44 import kotlinx.coroutines.flow.onEach in <lambda>()
[all …]
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/shade/domain/interactor/ |
| D | ShadeInteractorLegacyImpl.kt | 29 import kotlinx.coroutines.flow.Flow in <lambda>()
30 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
31 import kotlinx.coroutines.flow.StateFlow in <lambda>()
32 import kotlinx.coroutines.flow.combine in <lambda>()
33 import kotlinx.coroutines.flow.distinctUntilChanged in <lambda>()
34 import kotlinx.coroutines.flow.first in <lambda>()
35 import kotlinx.coroutines.flow.flow in <lambda>()
36 import kotlinx.coroutines.flow.stateIn in <lambda>()
119 return flow { in <lambda>()
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/volume/panel/component/anc/domain/interactor/ |
| D | AncSliceInteractor.kt | 30 import kotlinx.coroutines.flow.Flow in <lambda>()
31 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
32 import kotlinx.coroutines.flow.SharingStarted in <lambda>()
33 import kotlinx.coroutines.flow.StateFlow in <lambda>()
34 import kotlinx.coroutines.flow.combine in <lambda>()
35 import kotlinx.coroutines.flow.filter in <lambda>()
36 import kotlinx.coroutines.flow.flatMapLatest in <lambda>()
37 import kotlinx.coroutines.flow.flowOf in <lambda>()
38 import kotlinx.coroutines.flow.stateIn in <lambda>()
|
| /frameworks/base/packages/SystemUI/tests/utils/src/com/android/systemui/display/data/repository/ |
| D | FakeDeviceStateRepository.kt | 19 import kotlinx.coroutines.flow.MutableStateFlow
20 import kotlinx.coroutines.flow.StateFlow
24 private val flow = MutableStateFlow(DeviceStateRepository.DeviceState.UNKNOWN) constant
27 suspend fun emit(value: DeviceStateRepository.DeviceState) = flow.emit(value)
30 get() = flow
|