Home
last modified time | relevance | path

Searched refs:coroutineScope (Results 1 – 25 of 101) sorted by relevance

12345

/external/android_onboarding/java/com/android/onboarding/tasks/
DDefaultOnboardingTaskManager.kt11 private constructor(appContext: Context, coroutineScope: CoroutineScope) :
12 AbstractOnboardingTaskManager(appContext, coroutineScope) {
53 coroutineScope: CoroutineScope? = null, in initializeContractAndTaskMap()
60 coroutineScope ?: CoroutineScope(Dispatchers.Default + SupervisorJob()), in initializeContractAndTaskMap()
67 instance?.coroutineScope?.cancel() in initializeContractAndTaskMap()
DAbstractOnboardingTaskManager.kt22 protected val coroutineScope: CoroutineScope, constant in com.android.onboarding.tasks.AbstractOnboardingTaskManager
70 coroutineScope.launch { performTask(taskContract, task, taskArgs, taskToken) } in initializeContractAndTaskMap()
137 return coroutineScope.future { runTaskAndGetResult(taskContract, taskArgs) } in runTaskAndGetResultAsync()
150 return coroutineScope.future { runTaskAndGetResult(taskContract, task, taskArgs) } in runTaskAndGetResultAsync()
181 coroutineScope.future { waitForCompleted(taskToken) } in waitForCompletedAsync()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/
DCoroutineScopeTest.kt13 suspend fun callJobScoped() = coroutineScope { in <lambda>()
41 suspend fun callJobScoped() = coroutineScope { in <lambda>()
67 coroutineScope { in <lambda>()
80 suspend fun callJobScoped(): Unit = coroutineScope { in <lambda>()
100 suspend fun callJobScoped() = coroutineScope { in <lambda>()
148 private suspend fun failedConcurrentSumFirst(): Int = coroutineScope { in <lambda>()
178 private suspend fun failedConcurrentSumSecond(): Int = coroutineScope { in <lambda>()
199 suspend fun loadData() = coroutineScope { in <lambda>()
233 coroutineScope { in <lambda>()
289 coroutineScope { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/
DFlowInvariantsTest.kt108 coroutineScope { in <lambda>()
117 coroutineScope { in <lambda>()
120 coroutineScope { emit(value) } in <lambda>()
142 coroutineScope { in <lambda>()
145 coroutineScope { send(value) } in <lambda>()
160 coroutineScope { in <lambda>()
175 coroutineScope { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/
DBasicOperationsTest.kt125 private suspend fun testReceiveCatching(kind: TestChannelKind) = coroutineScope { in <lambda>()
153 private suspend fun testTrySendAfterClose(kind: TestChannelKind) = coroutineScope { in <lambda>()
171 private suspend fun testTrySendToFullChannel(kind: TestChannelKind) = coroutineScope { in <lambda>()
172 if (kind.isConflated || kind.capacity == Int.MAX_VALUE) return@coroutineScope in <lambda>()
192 coroutineScope { in <lambda>()
203 private suspend fun testSendReceive(kind: TestChannelKind, iterations: Int) = coroutineScope { in <lambda>()
/external/accompanist/web/src/main/java/com/google/accompanist/web/
DWebView.kt519 public class WebViewNavigator(private val coroutineScope: CoroutineScope) { constant in WebViewNavigator
605 coroutineScope.launch { in loadUrl()
622 coroutineScope.launch { in loadHtml()
639 coroutineScope.launch { in postUrl()
653 coroutineScope.launch { navigationEvents.emit(NavigationEvent.Back) } in navigateBack()
660 coroutineScope.launch { navigationEvents.emit(NavigationEvent.Forward) } in navigateForward()
667 coroutineScope.launch { navigationEvents.emit(NavigationEvent.Reload) } in reload()
674 coroutineScope.launch { navigationEvents.emit(NavigationEvent.StopLoading) } in stopLoading()
691 coroutineScope: CoroutineScope = rememberCoroutineScope() in rememberWebViewNavigator()
692 ): WebViewNavigator = remember(coroutineScope) { WebViewNavigator(coroutineScope) } in rememberWebViewNavigator()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/
DStackTraceRecoveryCustomExceptionsTest.kt78 coroutineScope<Unit> { in <lambda>()
90 coroutineScope<Unit> { in <lambda>()
136 coroutineScope<Unit> { in <lambda>()
155 coroutineScope<Unit> { in <lambda>()
/external/jetpack-camera-app/core/camera/src/main/java/com/google/jetpackcamera/core/camera/
DCoroutineCameraProvider.kt32 import kotlinx.coroutines.coroutineScope
45 ): R = coroutineScope { in runWith()
55 ): R = coroutineScope { in runWithConcurrent()
DConcurrentCameraSession.kt28 import kotlinx.coroutines.coroutineScope in <lambda>()
41 ) = coroutineScope { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/terminal/
DFirstTest.kt38 coroutineScope { in <lambda>()
67 coroutineScope { in <lambda>()
105 coroutineScope { in <lambda>()
140 coroutineScope { in <lambda>()
/external/lottie/snapshot-tests/src/androidTest/java/com/airbnb/lottie/snapshots/tests/
DProdAnimationsTestCase.kt21 import kotlinx.coroutines.coroutineScope in <lambda>()
31 override suspend fun SnapshotTestCaseContext.run() = coroutineScope { in <lambda>()
58 suspend fun SnapshotTestCaseContext.downloadAnimations() = coroutineScope { in <lambda>()
66 coroutineScope { in <lambda>()
DAssetsTestCase.kt11 import kotlinx.coroutines.coroutineScope in <lambda>()
16 override suspend fun SnapshotTestCaseContext.run() = coroutineScope { in <lambda>()
/external/accompanist/swiperefresh/src/main/java/com/google/accompanist/swiperefresh/
DSwipeRefresh.kt140 private val coroutineScope: CoroutineScope, constant in SwipeRefreshNestedScrollConnection
184 coroutineScope.launch { in onScroll()
274 val coroutineScope = rememberCoroutineScope() constant
288 val nestedScrollConnection = remember(state, coroutineScope) { in <lambda>()
289 SwipeRefreshNestedScrollConnection(state, coroutineScope) { in <lambda>()
/external/jetpack-camera-app/core/camera/src/main/java/com/google/jetpackcamera/core/camera/effects/
DSingleSurfaceForcingEffect.kt32 class SingleSurfaceForcingEffect(coroutineScope: CoroutineScope) : CameraEffect(
35 CopyingSurfaceProcessor(coroutineScope),
DCopyingSurfaceProcessor.kt42 import kotlinx.coroutines.coroutineScope in <lambda>()
58 class CopyingSurfaceProcessor(coroutineScope: CoroutineScope) : SurfaceProcessor { in <lambda>()
64 coroutineScope.launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
78 coroutineScope inputScope@{ in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DThreadContextElementRestoreTest.kt22 coroutineScope { in <lambda>()
129 coroutineScope { in <lambda>()
136 coroutineScope { in <lambda>()
DJobCancellationExceptionSerializerTest.kt14 coroutineScope { in <lambda>()
43 coroutineScope { in <lambda>()
DThreadLocalStressTest.kt137 coroutineScope { in doTest()
151 coroutineScope { in doTestWithContextSwitch()
/external/oboe/samples/minimaloboe/src/main/kotlin/com/example/minimaloboe/
DAudioPlayer.kt35 private val coroutineScope = CoroutineScope(Dispatchers.Default) + Job() constant
48 coroutineScope.launch { in setPlaybackEnabled()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/
DTakeWhileTest.kt32 coroutineScope { in <lambda>()
50 coroutineScope { in <lambda>()
DFilterTest.kt28 coroutineScope { in <lambda>()
63 coroutineScope { in <lambda>()
DTakeTest.kt64 coroutineScope { in <lambda>()
81 coroutineScope { in <lambda>()
DDistinctUntilChangedTest.kt57 coroutineScope { in <lambda>()
74 coroutineScope { in <lambda>()
/external/jetpack-camera-app/core/common/src/test/java/com/google/jetpackcamera/core/common/
DRefCountedTest.kt21 import kotlinx.coroutines.coroutineScope
111 coroutineScope { in <lambda>()
/external/kotlinx.coroutines/integration-testing/smokeTest/src/commonMain/kotlin/
DSample.kt3 suspend fun doWorld() = coroutineScope { in doWorld()

12345