Home
last modified time | relevance | path

Searched refs:newSingleThreadContext (Results 1 – 25 of 30) sorted by relevance

12

/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DExecutorsTest.kt20 val context = newSingleThreadContext("TestThread") in <lambda>()
86 val ctx1 = newSingleThreadContext("Ctx1") in <lambda>()
87 val ctx2 = newSingleThreadContext("Ctx2") in <lambda>()
DThreadContextElementTest.kt61 newSingleThreadContext("withContext").use { in <lambda>()
DRunBlockingTest.kt58 val thread = newSingleThreadContext(name) in testOtherDispatcher()
DThreadLocalTest.kt184 newSingleThreadContext("withContext").use { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/
Dexample-context-04.kt13 newSingleThreadContext("Ctx1").use { ctx1 -> in <lambda>()
14 newSingleThreadContext("Ctx2").use { ctx2 -> in <lambda>()
Dexample-context-01.kt20 launch(newSingleThreadContext("MyOwnThread")) { // will get its own new thread in <lambda>()
Dexample-sync-05.kt26 val counterContext = newSingleThreadContext("CounterContext")
Dexample-sync-04.kt26 val counterContext = newSingleThreadContext("CounterContext")
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/sync/
DMutexStressTest.kt35 newSingleThreadContext("SemaphoreStressTest").use { pool -> in <lambda>()
65 newSingleThreadContext("SemaphoreStressTest").use { pool -> in <lambda>()
DSemaphoreStressTest.kt68 newSingleThreadContext("SemaphoreStressTest").use { pool -> in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-test/test/
DTestCoroutineScopeTest.kt23 TestCoroutineScope(newSingleThreadContext("incorrect call")) in <lambda>()
DTestDispatchersTest.kt29 newSingleThreadContext("testSingleThread").use { threadPool -> in <lambda>()
DTestRunBlockingTest.kt286 runBlockingTest(newSingleThreadContext("name")) { in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/
DFluxContextTest.kt16 private val dispatcher = newSingleThreadContext("FluxContextTest")
DFlowAsFluxTest.kt118 newSingleThreadContext(threadName).use { dispatcher -> in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/
DFlowableContextTest.kt16 private val dispatcher = newSingleThreadContext("FlowableContextTest")
DFlowAsFlowableTest.kt59 newSingleThreadContext(threadName).use { dispatcher -> in <lambda>()
DFlowAsObservableTest.kt185 newSingleThreadContext(threadName).use { dispatcher -> in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/
DFlowableContextTest.kt16 private val dispatcher = newSingleThreadContext("FlowableContextTest")
DFlowAsFlowableTest.kt59 newSingleThreadContext(threadName).use { dispatcher -> in <lambda>()
DFlowAsObservableTest.kt185 newSingleThreadContext(threadName).use { dispatcher -> in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/
DThreadPoolDispatcher.kt35 public fun newSingleThreadContext(name: String): ExecutorCoroutineDispatcher = in <lambda>() method
/external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/test/
DJavaFxObservableAsFlowTest.kt29 newSingleThreadContext("setter").use { pool -> in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/
DFlowAsPublisherTest.kt122 newSingleThreadContext(threadName).use { dispatcher -> in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/
DREADME.md20 | [newSingleThreadContext] | Creates a single-threaded coroutine context
108 [newSingleThreadContext]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotli…

12