| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | SanitizedProbesTest.kt | 106 private fun CoroutineScope.launchSelector(): Job { in launchSelector() method
119 private fun CoroutineScope.createActiveDeferred(): Deferred<*> = async { in <lambda>() method
128 private fun CoroutineScope.createDeferred(): Deferred<*> = createDeferredNested() in createDeferred() method
130 private fun CoroutineScope.createDeferredNested(): Deferred<*> = async(NonCancellable) { in createDeferred() method
|
| D | RunningThreadStackMergeTest.kt | 50 private fun CoroutineScope.launchCoroutine() { in CoroutineScope() method
98 private fun CoroutineScope.launchEscapingCoroutine() { in CoroutineScope() method
137 private fun CoroutineScope.launchEscapingCoroutineWithoutContext() { in CoroutineScope() method
|
| D | ToStringTest.kt | 48 private fun CoroutineScope.launchDelayed(): Job { in launchDelayed() method
113 private fun CoroutineScope.launchHierarchy(isCompleting: Boolean): Job { in CoroutineScope() method
|
| D | DumpWithoutCreationStackTraceTest.kt | 36 private fun CoroutineScope.createActiveDeferred(): Deferred<*> = async { in <lambda>() method
|
| D | DebugProbesTest.kt | 13 private fun CoroutineScope.createDeferred(): Deferred<*> = async(NonCancellable) { in createDeferred() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-channel-06.kt | 18 fun CoroutineScope.produceNumbers() = produce<Int> { in <lambda>() method
26 fun CoroutineScope.launchProcessor(id: Int, channel: ReceiveChannel<Int>) = launch { in <lambda>() method
|
| D | example-channel-04.kt | 21 fun CoroutineScope.produceNumbers() = produce<Int> { in <lambda>() method
26 fun CoroutineScope.square(numbers: ReceiveChannel<Int>): ReceiveChannel<Int> = produce { in <lambda>() method
|
| D | example-channel-05.kt | 21 fun CoroutineScope.numbersFrom(start: Int) = produce<Int> { in <lambda>() method
26 fun CoroutineScope.filter(numbers: ReceiveChannel<Int>, prime: Int) = produce<Int> { in filter() method
|
| D | example-select-01.kt | 12 fun CoroutineScope.fizz() = produce<String> { in <lambda>() method
19 fun CoroutineScope.buzz() = produce<String> { in <lambda>() method
|
| D | example-select-05.kt | 12 fun CoroutineScope.switchMapDeferreds(input: ReceiveChannel<Deferred<String>>) = produce<String> { in <lambda>() method
33 fun CoroutineScope.asyncString(str: String, time: Long) = async { in <lambda>() method
|
| D | example-select-04.kt | 12 fun CoroutineScope.asyncString(time: Int) = async { in <lambda>() method
17 fun CoroutineScope.asyncStringsList(): List<Deferred<String>> { in asyncStringsList() method
|
| D | example-channel-03.kt | 11 fun CoroutineScope.produceSquares(): ReceiveChannel<Int> = produce { in <lambda>() method
|
| D | example-select-03.kt | 12 fun CoroutineScope.produceNumbers(side: SendChannel<Int>) = produce<Int> { in <lambda>() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | CoroutineScope.kt | 64 public interface CoroutineScope { in <lambda>() interface
206 public fun CoroutineScope(context: CoroutineContext): CoroutineScope = in CoroutineScope() method
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| D | PingPongActorBenchmark.kt | 64 fun CoroutineScope.pingActorCoroutine( in CoroutineScope() method
88 fun CoroutineScope.pongActorCoroutine(capacity: Int = 1) = in pongActorCoroutine() method
|
| D | StatefulActorBenchmark.kt | 81 …private fun CoroutineScope.requestorActor(computations: List<SendChannel<Letter>>, stopChannel: Ch… in requestorActor() method
101 fun CoroutineScope.computationActor(stateSize: Int = STATE_SIZE) = in computationActor() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ChannelSelectStressTest.kt | 50 private fun CoroutineScope.launchSender() { in CoroutineScope() method
61 private fun CoroutineScope.launchReceiver() { in launchReceiver() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | BlockingCoroutineDispatcherWorkSignallingStressTest.kt | 52 private fun CoroutineScope.blockingAwait( in CoroutineScope() method
58 private fun CoroutineScope.cpuAwait( in CoroutineScope() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublisherCompletionStressTest.kt | 15 …private fun CoroutineScope.range(context: CoroutineContext, start: Int, count: Int) = flowPublish(… in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | ObservableCompletionStressTest.kt | 15 …private fun CoroutineScope.range(context: CoroutineContext, start: Int, count: Int) = rxObservable… in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublisherCompletionStressTest.kt | 15 …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 | 15 …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 | 16 …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 | 62 private fun CoroutineScope.wrappedCurrentDispatcher() = object : CoroutineDispatcher() { in String() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | StackTraceRecoveryNestedScopesTest.kt | 27 private fun CoroutineScope.createFailingAsync() = async { in failure() method
|