/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/ |
D | StateFlowTest.kt | 12 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>()
|
D | StateInTest.kt | 15 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/ |
D | CameraSessionContext.kt | 24 import kotlinx.coroutines.flow.MutableStateFlow 40 val currentCameraState: MutableStateFlow<CameraState>, 41 val surfaceRequests: MutableStateFlow<SurfaceRequest?>, 43 var zoomScale: MutableStateFlow<Float>
|
D | CameraXCameraUseCase.kt | 69 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/ |
D | StateFlow.kt | 158 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/ |
D | ScreenFlash.kt | 20 import kotlinx.coroutines.flow.MutableStateFlow 42 private val _screenFlashUiState: MutableStateFlow<ScreenFlashUiState> = 43 MutableStateFlow(ScreenFlashUiState())
|
D | PreviewViewModel.kt | 71 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/ |
D | PermissionsViewModel.kt | 29 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/ |
D | ConstraintsRepository.kt | 20 import kotlinx.coroutines.flow.MutableStateFlow 34 private val _systemConstraints = MutableStateFlow<SystemConstraints?>(null) in updateSystemConstraints()
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/flow/ |
D | StateFlowUpdateCommonTest.kt | 21 private fun doTest(increment: MutableStateFlow<Int>.() -> Unit) = runTest { in <lambda>() 22 val flow = MutableStateFlow(0) in <lambda>()
|
D | StateFlowCommonStressTest.kt | 10 private val state = MutableStateFlow<Long>(0) in <lambda>()
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
D | StateFlowUpdateStressTest.kt | 24 private fun doTest(increment: MutableStateFlow<Int>.() -> Unit) = runTest { in <lambda>() 25 val flow = MutableStateFlow(0) in <lambda>()
|
D | SharingStressTest.kt | 86 val subCount = MutableStateFlow(0) in <lambda>() 143 subCount: MutableStateFlow<Int>, in <lambda>() 190 private fun MutableStateFlow<Int>.increment(delta: Int) { in <lambda>() method
|
D | StateFlowCancellabilityTest.kt | 13 val state = MutableStateFlow(0) in <lambda>()
|
D | StateFlowStressTest.kt | 10 private val state = MutableStateFlow<Long>(0) in <lambda>()
|
/external/jetpack-camera-app/feature/postcapture/src/main/java/com/google/jetpackcamera/feature/postcapture/ |
D | PostCaptureViewModel.kt | 22 import kotlinx.coroutines.flow.MutableStateFlow 29 private val _uiState = MutableStateFlow(PostCaptureUiState())
|
/external/kotlinx.coroutines/kotlinx-coroutines-test/common/test/ |
D | UnconfinedTestDispatcherTest.kt | 69 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/ |
D | Share.kt | 309 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/ |
D | DocsSamples.kt | 31 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/ |
D | AudioPlayer.kt | 24 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/ |
D | BottomSheetNavigator.kt | 46 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/ |
D | FakeCameraUseCase.kt | 39 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/ |
D | CopyingSurfaceProcessor.kt | 44 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/ |
D | ReusableContinuationStressTest.kt | 23 val stateFlow = MutableStateFlow(0) in <lambda>()
|
/external/lottie/snapshot-tests/src/androidTest/java/com/airbnb/lottie/snapshots/ |
D | SnapshotTestCaseContext.kt | 32 import kotlinx.coroutines.flow.MutableStateFlow in <lambda>() 178 val LocalSnapshotReady = compositionLocalOf { MutableStateFlow<Boolean?>(true) } in <lambda>() 193 val readyFlow = MutableStateFlow<Boolean?>(null) in snapshotComposable()
|