| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | SanitizedProbesTest.kt | 104 private fun CoroutineScope.launchSelector(): Job { in launchSelector() method
117 private fun CoroutineScope.createActiveDeferred(): Deferred<*> = async { in <lambda>() method
126 private fun CoroutineScope.createDeferred(): Deferred<*> = createDeferredNested() in createDeferred() method
128 private fun CoroutineScope.createDeferredNested(): Deferred<*> = async(NonCancellable) { in createDeferred() method
|
| D | RunningThreadStackMergeTest.kt | 44 private fun CoroutineScope.launchCoroutine() { in CoroutineScope() method
89 private fun CoroutineScope.launchEscapingCoroutine() { in CoroutineScope() method
125 private fun CoroutineScope.launchEscapingCoroutineWithoutContext() { in CoroutineScope() method
|
| D | DumpWithCreationStackTraceTest.kt | 39 private fun CoroutineScope.createActiveDeferred(): Deferred<*> = async { in <lambda>() method
|
| D | ToStringTest.kt | 46 private fun CoroutineScope.launchDelayed(): Job { in launchDelayed() method
113 private fun CoroutineScope.launchHierarchy(isCompleting: Boolean): Job { in CoroutineScope() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-channel-06.kt | 14 fun CoroutineScope.produceNumbers() = produce<Int> { in <lambda>() method
22 fun CoroutineScope.launchProcessor(id: Int, channel: ReceiveChannel<Int>) = launch { in <lambda>() method
|
| D | example-channel-04.kt | 17 fun CoroutineScope.produceNumbers() = produce<Int> { in <lambda>() method
22 fun CoroutineScope.square(numbers: ReceiveChannel<Int>): ReceiveChannel<Int> = produce { in <lambda>() method
|
| D | example-channel-05.kt | 17 fun CoroutineScope.numbersFrom(start: Int) = produce<Int> { in <lambda>() method
22 fun CoroutineScope.filter(numbers: ReceiveChannel<Int>, prime: Int) = produce<Int> { in filter() method
|
| D | example-select-01.kt | 8 fun CoroutineScope.fizz() = produce<String> { in <lambda>() method
15 fun CoroutineScope.buzz() = produce<String> { in <lambda>() method
|
| D | example-select-05.kt | 8 fun CoroutineScope.switchMapDeferreds(input: ReceiveChannel<Deferred<String>>) = produce<String> { in <lambda>() method
29 fun CoroutineScope.asyncString(str: String, time: Long) = async { in <lambda>() method
|
| D | example-select-04.kt | 8 fun CoroutineScope.asyncString(time: Int) = async { in <lambda>() method
13 fun CoroutineScope.asyncStringsList(): List<Deferred<String>> { in asyncStringsList() method
|
| D | example-channel-03.kt | 7 fun CoroutineScope.produceSquares(): ReceiveChannel<Int> = produce { in <lambda>() method
|
| D | example-select-03.kt | 8 fun CoroutineScope.produceNumbers(side: SendChannel<Int>) = produce<Int> { in <lambda>() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | CoroutineScope.kt | 75 public interface CoroutineScope { in <lambda>() interface
297 public fun CoroutineScope(context: CoroutineContext): CoroutineScope = in CoroutineScope() method
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| D | PingPongActorBenchmark.kt | 60 fun CoroutineScope.pingActorCoroutine( in CoroutineScope() method
84 fun CoroutineScope.pongActorCoroutine(capacity: Int = 1) = in pongActorCoroutine() method
|
| D | StatefulActorBenchmark.kt | 77 …private fun CoroutineScope.requestorActor(computations: List<SendChannel<Letter>>, stopChannel: Ch… in requestorActor() method
97 fun CoroutineScope.computationActor(stateSize: Int = STATE_SIZE) = in computationActor() method
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-android/test/ |
| D | HandlerDispatcherTest.kt | 83 private fun CoroutineScope.doTestAwaitFrame() { in CoroutineScope() method
98 private fun CoroutineScope.doTestAwaitWithDetectedChoreographer() { in CoroutineScope() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ChannelSelectStressTest.kt | 47 private fun CoroutineScope.launchSender() { in CoroutineScope() method
58 private fun CoroutineScope.launchReceiver() { in launchReceiver() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/jvm/test/ |
| D | DumpOnTimeoutTest.kt | 38 fun CoroutineScope.uniquelyNamedFunction() { in uniquelyNamedFunction() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | BlockingCoroutineDispatcherWorkSignallingStressTest.kt | 49 private fun CoroutineScope.blockingAwait( in CoroutineScope() method
55 private fun CoroutineScope.cpuAwait( in CoroutineScope() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublisherCompletionStressTest.kt | 12 …private fun CoroutineScope.range(context: CoroutineContext, start: Int, count: Int) = flowPublish(… in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublisherCompletionStressTest.kt | 12 …private fun CoroutineScope.range(context: CoroutineContext, start: Int, count: Int) = publish(cont… in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | ObservableCompletionStressTest.kt | 12 …private fun CoroutineScope.range(context: CoroutineContext, start: Int, count: Int) = rxObservable… in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | FluxCompletionStressTest.kt | 13 …private fun CoroutineScope.range(context: CoroutineContext, start: Int, count: Int) = flux(context… in <lambda>() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | CoroutineDispatcherOperatorFunInvokeTest.kt | 59 private fun CoroutineScope.wrappedCurrentDispatcher() = object : CoroutineDispatcher() { in String() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | StackTraceRecoveryNestedScopesTest.kt | 28 private fun CoroutineScope.createFailingAsync() = async { in failure() method
|