| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ExecutorsTest.kt | 20 val context = newSingleThreadContext("TestThread") in <lambda>()
86 val ctx1 = newSingleThreadContext("Ctx1") in <lambda>()
87 val ctx2 = newSingleThreadContext("Ctx2") in <lambda>()
|
| D | ThreadContextElementTest.kt | 60 newSingleThreadContext("withContext").use { in <lambda>()
94 newSingleThreadContext("withContext").use { in <lambda>()
113 newSingleThreadContext("withContext").use { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-context-04.kt | 13 newSingleThreadContext("Ctx1").use { ctx1 -> in <lambda>()
14 newSingleThreadContext("Ctx2").use { ctx2 -> in <lambda>()
|
| D | example-context-01.kt | 20 launch(newSingleThreadContext("MyOwnThread")) { // will get its own new thread in <lambda>()
|
| D | example-sync-05.kt | 26 val counterContext = newSingleThreadContext("CounterContext")
|
| D | example-sync-04.kt | 26 val counterContext = newSingleThreadContext("CounterContext")
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/sync/ |
| D | MutexStressTest.kt | 21 newSingleThreadContext("testSingleThreadContext").use { in <lambda>()
62 newSingleThreadContext("SemaphoreStressTest").use { pool -> in <lambda>()
92 newSingleThreadContext("SemaphoreStressTest").use { pool -> in <lambda>()
|
| D | SemaphoreStressTest.kt | 96 newSingleThreadContext("SemaphoreStressTest").use { pool -> in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/src/ |
| D | MultithreadedDispatchers.common.kt | 8 public expect fun newSingleThreadContext(name: String): CloseableCoroutineDispatcher method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | ThreadPoolDispatcher.kt | 34 public actual fun newSingleThreadContext(name: String): ExecutorCoroutineDispatcher = in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | FluxContextTest.kt | 16 private val dispatcher = newSingleThreadContext("FluxContextTest")
|
| D | FlowAsFluxTest.kt | 118 newSingleThreadContext(threadName).use { dispatcher -> in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | FlowableContextTest.kt | 16 private val dispatcher = newSingleThreadContext("FlowableContextTest")
|
| D | FlowAsFlowableTest.kt | 59 newSingleThreadContext(threadName).use { dispatcher -> in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | FlowableContextTest.kt | 16 private val dispatcher = newSingleThreadContext("FlowableContextTest")
|
| D | FlowAsFlowableTest.kt | 59 newSingleThreadContext(threadName).use { dispatcher -> in <lambda>()
|
| D | FlowAsObservableTest.kt | 185 newSingleThreadContext(threadName).use { dispatcher -> in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/ |
| D | LimitedParallelismConcurrentTest.kt | 49 val executor = newSingleThreadContext("test") in <lambda>()
|
| D | ConcurrentExceptionsStressTest.kt | 27 newSingleThreadContext("JobExceptionsStressTest-$index") in <lambda>()
|
| D | RunBlockingTest.kt | 58 val thread = newSingleThreadContext(name) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/knit/ |
| D | ClosedAfterGuideTestExecutor.kt | 11 internal fun newSingleThreadContext(name: String): ExecutorCoroutineDispatcher = ClosedAfterGuideTe… in newSingleThreadContext() method
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/test/ |
| D | JavaFxObservableAsFlowTest.kt | 29 newSingleThreadContext("setter").use { pool -> in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | MultithreadedDispatchers.kt | 13 public actual fun newSingleThreadContext(name: String): CloseableCoroutineDispatcher { in <lambda>() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/jvm/test/ |
| D | MultithreadingTest.kt | 29 newSingleThreadContext("testSingleThread").use { threadPool -> in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | FlowAsPublisherTest.kt | 123 newSingleThreadContext(threadName).use { dispatcher -> in <lambda>()
|