Home
last modified time | relevance | path

Searched refs:MutableStateFlow (Results 1 – 25 of 35) sorted by relevance

12

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/
DStateFlowTest.kt12 val state = MutableStateFlow<Int?>(0) in <lambda>()
52 val state = MutableStateFlow(Data(0)) in <lambda>()
103 private val _counter = MutableStateFlow(0) in <lambda>()
116 val state = MutableStateFlow("A") in <lambda>()
156 val state = MutableStateFlow(String) in <lambda>()
167 val state = MutableStateFlow(42) in <lambda>()
175 val state = MutableStateFlow(0) in <lambda>()
184 testSubscriptionByFirstSuspensionInCollect(MutableStateFlow(0)) { value = it; yield() } in <lambda>()
DStateInTest.kt15 assertTrue(state !is MutableStateFlow<*>) // cannot be cast to mutable state flow in <lambda>()
/external/jetpack-camera-app/core/camera/src/main/java/com/google/jetpackcamera/core/camera/
DCameraSessionContext.kt24 import kotlinx.coroutines.flow.MutableStateFlow
40 val currentCameraState: MutableStateFlow<CameraState>,
41 val surfaceRequests: MutableStateFlow<SurfaceRequest?>,
43 var zoomScale: MutableStateFlow<Float>
DCameraXCameraUseCase.kt69 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
111 private val currentSettings = MutableStateFlow<CameraAppSettings?>(null) in <lambda>()
114 private var _currentCameraState = MutableStateFlow(CameraState()) in <lambda>()
117 private val _surfaceRequest = MutableStateFlow<SurfaceRequest?>(null) in <lambda>()
286 val transientSettings = MutableStateFlow<TransientSessionSettings?>(null) in <lambda>()
287 val cameraSessionZoomScale = MutableStateFlow(1f) in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/
DStateFlow.kt158 public interface MutableStateFlow<T> : StateFlow<T>, MutableSharedFlow<T> { interface
187 public fun <T> MutableStateFlow(value: T): MutableStateFlow<T> = StateFlowImpl(value ?: NULL) in compareAndSet() method
197 public inline fun <T> MutableStateFlow<T>.updateAndGet(function: (T) -> T): T { in compareAndSet()
213 public inline fun <T> MutableStateFlow<T>.getAndUpdate(function: (T) -> T): T { in getAndUpdate()
229 public inline fun <T> MutableStateFlow<T>.update(function: (T) -> T) { in update()
315 ) : AbstractSharedFlow<StateFlowSlot>(), MutableStateFlow<T>, CancellableFlow<T>, FusibleFlow<T> {
/external/jetpack-camera-app/feature/preview/src/main/java/com/google/jetpackcamera/feature/preview/
DScreenFlash.kt20 import kotlinx.coroutines.flow.MutableStateFlow
42 private val _screenFlashUiState: MutableStateFlow<ScreenFlashUiState> =
43 MutableStateFlow(ScreenFlashUiState())
DPreviewViewModel.kt71 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
97 private val _previewUiState: MutableStateFlow<PreviewUiState> = in <lambda>()
98 MutableStateFlow(PreviewUiState.NotReady) in <lambda>()
99 private val lockedRecordingState: MutableStateFlow<Boolean> = MutableStateFlow(false) in <lambda>()
/external/jetpack-camera-app/feature/permissions/src/main/java/com/google/jetpackcamera/permissions/
DPermissionsViewModel.kt29 import kotlinx.coroutines.flow.MutableStateFlow
53 private val _permissionsUiState: MutableStateFlow<PermissionsUiState> =
54 MutableStateFlow(getCurrentPermission())
/external/jetpack-camera-app/data/settings/src/main/java/com/google/jetpackcamera/settings/
DConstraintsRepository.kt20 import kotlinx.coroutines.flow.MutableStateFlow
34 private val _systemConstraints = MutableStateFlow<SystemConstraints?>(null) in updateSystemConstraints()
/external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/flow/
DStateFlowUpdateCommonTest.kt21 private fun doTest(increment: MutableStateFlow<Int>.() -> Unit) = runTest { in <lambda>()
22 val flow = MutableStateFlow(0) in <lambda>()
DStateFlowCommonStressTest.kt10 private val state = MutableStateFlow<Long>(0) in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/
DStateFlowUpdateStressTest.kt24 private fun doTest(increment: MutableStateFlow<Int>.() -> Unit) = runTest { in <lambda>()
25 val flow = MutableStateFlow(0) in <lambda>()
DSharingStressTest.kt86 val subCount = MutableStateFlow(0) in <lambda>()
143 subCount: MutableStateFlow<Int>, in <lambda>()
190 private fun MutableStateFlow<Int>.increment(delta: Int) { in <lambda>() method
DStateFlowCancellabilityTest.kt13 val state = MutableStateFlow(0) in <lambda>()
DStateFlowStressTest.kt10 private val state = MutableStateFlow<Long>(0) in <lambda>()
/external/jetpack-camera-app/feature/postcapture/src/main/java/com/google/jetpackcamera/feature/postcapture/
DPostCaptureViewModel.kt22 import kotlinx.coroutines.flow.MutableStateFlow
29 private val _uiState = MutableStateFlow(PostCaptureUiState())
/external/kotlinx.coroutines/kotlinx-coroutines-test/common/test/
DUnconfinedTestDispatcherTest.kt69 val subject1 = MutableStateFlow(1) in <lambda>()
70 val subject2 = MutableStateFlow("a") in <lambda>()
120 val stateFlow = MutableStateFlow(0) in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/
DShare.kt309 val state = MutableStateFlow(initialValue) in stateIn()
335 var state: MutableStateFlow<T>? = null in launchSharingDeferred()
338 state = MutableStateFlow(value).also { in launchSharingDeferred()
363 public fun <T> MutableStateFlow<T>.asStateFlow(): StateFlow<T> = in asSharedFlow()
/external/accompanist/sample/src/main/java/com/google/accompanist/sample/swiperefresh/
DDocsSamples.kt31 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
37 private val _isRefreshing = MutableStateFlow(false) in <lambda>()
/external/oboe/samples/minimaloboe/src/main/kotlin/com/example/minimaloboe/
DAudioPlayer.kt24 import kotlinx.coroutines.flow.MutableStateFlow
36 private var _playerState = MutableStateFlow<PlayerState>(PlayerState.NoResultYet)
/external/accompanist/navigation-material/src/main/java/com/google/accompanist/navigation/material/
DBottomSheetNavigator.kt46 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
131 MutableStateFlow(emptyList())
143 MutableStateFlow(emptySet())
/external/jetpack-camera-app/core/camera/src/main/java/com/google/jetpackcamera/core/camera/test/
DFakeCameraUseCase.kt39 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
63 private val currentSettings = MutableStateFlow(defaultCameraSettings) in <lambda>()
152 private val _currentCameraState = MutableStateFlow(CameraState()) in <lambda>()
160 private val _surfaceRequest = MutableStateFlow<SurfaceRequest?>(null) in <lambda>()
/external/jetpack-camera-app/core/camera/src/main/java/com/google/jetpackcamera/core/camera/effects/
DCopyingSurfaceProcessor.kt44 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
60 private val inputSurfaceFlow = MutableStateFlow<SurfaceRequestScope?>(null) in <lambda>()
61 private val outputSurfaceFlow = MutableStateFlow<SurfaceOutputScope?>(null) in <lambda>()
85 val frameUpdateFlow = MutableStateFlow(0) in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DReusableContinuationStressTest.kt23 val stateFlow = MutableStateFlow(0) in <lambda>()
/external/lottie/snapshot-tests/src/androidTest/java/com/airbnb/lottie/snapshots/
DSnapshotTestCaseContext.kt32 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>()
178 val LocalSnapshotReady = compositionLocalOf { MutableStateFlow<Boolean?>(true) } in <lambda>()
193 val readyFlow = MutableStateFlow<Boolean?>(null) in snapshotComposable()

12