Home
last modified time | relevance | path

Searched refs:continuation (Results 1 – 14 of 14) sorted by relevance

/core/core-telecom/src/main/java/androidx/core/telecom/extensions/
DCallExtensionScopeImpl.kt418 private suspend fun waitForCallReady() = suspendCancellableCoroutine { continuation -> in <lambda>() method
424 continuation.resume(Unit) in <lambda>()
429 continuation.invokeOnCancellation { call.unregisterCallback(callback) } in <lambda>()
477 suspendCancellableCoroutine { continuation -> in <lambda>() method
489 continuation.resume( in <lambda>()
552 suspendCancellableCoroutine { continuation -> in <lambda>() method
556 if (targetCall == null || call != targetCall || continuation.isCompleted) in <lambda>()
558 continuation.resume(Unit) in <lambda>()
566 continuation.resume(Unit) in <lambda>()
572 continuation.invokeOnCancellation { call.unregisterCallback(callback) } in <lambda>()
[all …]
DMeetingSummaryRemoteImpl.kt115 ): Unit = suspendCancellableCoroutine { continuation -> in <lambda>() method
121 finishSync = { callScope.launch { continuation.resume(Unit) } } in <lambda>()
130 continuation.resumeWithException(e) // Propagate the exception in <lambda>()
DCallIconExtensionRemoteImpl.kt95 ): Unit = suspendCancellableCoroutine { continuation -> in <lambda>() method
104 finishSync = { callScope.launch { continuation.resume(Unit) } } in <lambda>()
DLocalCallSilenceExtensionRemoteImpl.kt100 ): LocalCallSilenceActionsRemote? = suspendCancellableCoroutine { continuation -> in <lambda>() method
117 callScope.launch { continuation.resume(remoteBinder) } in <lambda>()
DParticipantExtensionRemoteImpl.kt182 ): ParticipantActionsRemote? = suspendCancellableCoroutine { continuation -> in connectActionsToRemote() method
206 continuation.resume(remoteBinder) in connectActionsToRemote()
/core/core-ktx/src/androidTest/java/androidx/core/util/
DAndroidXConsumerTest.kt27 val continuation = TestContinuation<Boolean>() in consumerResumed() constant
28 val consumer = continuation.asAndroidXConsumer() in consumerResumed()
34 assertEquals(true, continuation.result?.getOrThrow()) in consumerResumed()
DRunnableTest.kt27 val continuation = TestContinuation<Unit>() in runnableResumed() constant
28 val runnable = continuation.asRunnable() in runnableResumed()
34 assertEquals(Unit, continuation.result?.getOrNull()) in runnableResumed()
DConsumerTest.kt29 val continuation = TestContinuation<Boolean>() in consumerResumed() constant
30 val consumer = continuation.asConsumer() in consumerResumed()
36 assertEquals(true, continuation.result?.getOrThrow()) in consumerResumed()
/core/core-ktx/src/main/java/androidx/core/os/
DOutcomeReceiver.kt62 private val continuation: Continuation<R> in asOutcomeReceiver() constant in androidx.core.os.ContinuationOutcomeReceiver
68 continuation.resume(result) in asOutcomeReceiver()
76 continuation.resumeWithException(error) in asOutcomeReceiver()
/core/core-ktx/src/androidTest/java/androidx/core/os/
DOutcomeReceiverTest.kt32 val continuation = TestContinuation<Boolean>() in outcomeReceiverResumed() constant
33 val outcomeReceiver: OutcomeReceiver<Boolean, Exception> = continuation.asOutcomeReceiver() in outcomeReceiverResumed()
38 assertEquals(true, continuation.result?.getOrThrow()) in outcomeReceiverResumed()
/core/core-ktx/src/main/java/androidx/core/util/
DRunnable.kt53 private class ContinuationRunnable(private val continuation: Continuation<Unit>) : in asRunnable() constant in androidx.core.util.ContinuationRunnable
59 continuation.resume(Unit) in asRunnable()
DAndroidXConsumer.kt54 private class AndroidXContinuationConsumer<T>(private val continuation: Continuation<T>) : in asAndroidXConsumer() constant in androidx.core.util.AndroidXContinuationConsumer
60 continuation.resume(value) in asAndroidXConsumer()
DPlatformConsumer.kt61 private class ContinuationConsumer<T>(private val continuation: Continuation<T>) : in asConsumer() constant in androidx.core.util.ContinuationConsumer
67 continuation.resume(value) in asConsumer()
/core/core-telecom/integration-tests/testicsapp/src/main/java/androidx/core/telecom/test/services/
DCallAudioRouteResolver.kt167 suspendCancellableCoroutine { continuation -> in <lambda>() method
174 continuation.resume(true) in <lambda>()
178 continuation.resume(false) in <lambda>()