1 files changed, 102 insertions, 0 deletions
diff --git a/kotlinx-coroutines-core/common/test/ExperimentalDispatchModeTest.kt b/kotlinx-coroutines-core/common/test/ExperimentalDispatchModeTest.kt
new file mode 100644
index 00000000..37e61824
--- /dev/null
+++ b/kotlinx-coroutines-core/common/test/ExperimentalDispatchModeTest.kt
@@ -0,0 +1,102 @@
+/*
+ * Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+package kotlinx.coroutines
+
+import kotlin.test.*
+
+class ExperimentalDispatchModeTest : TestBase() {
+    @Test
+    fun testUnconfinedCancellation() = runTest {
+        val parent = Job()
+        launch(parent) {
+            expect(1)
+            parent.cancel()
+            launch(Dispatchers.Unconfined) {
+                expectUnreached()
+            }
+
+        }.join()
+        finish(2)
+    }
+
+    @Test
+    fun testUnconfinedCancellationState() = runTest {
+        val parent = Job()
+        launch(parent) {
+            expect(1)
+            parent.cancel()
+            val job = launch(Dispatchers.Unconfined) {
+                expectUnreached()
+            }
+
+            assertTrue(job.isCancelled)
+            assertTrue(job.isCompleted)
+            assertFalse(job.isActive)
+        }.join()
+        finish(2)
+    }
+
+    @Test
+    fun testUnconfinedCancellationLazy() = runTest {
+        val parent = Job()
+        launch(parent) {
+            expect(1)
+            val job = launch(Dispatchers.Unconfined, start = CoroutineStart.LAZY) {
+                expectUnreached()
+            }
+            job.invokeOnCompletion { expect(2) }
+            assertFalse(job.isCompleted)
+
+            parent.cancel()
+            job.join()
+        }.join()
+        finish(3)
+    }
+
+    @Test
+    fun testUndispatchedCancellation() = runTest {
+        val parent = Job()
+        launch(parent) {
+            expect(1)
+            parent.cancel()
+            launch(start = CoroutineStart.UNDISPATCHED) {
+                expect(2)
+                yield()
+                expectUnreached()
+            }
+
+        }.join()
+        finish(3)
+    }
+
+    @Test
+    fun testCancelledAtomicUnconfined() = runTest {
+        val parent = Job()
+        launch(parent) {
+            expect(1)
+            parent.cancel()
+            launch(Dispatchers.Unconfined, start = CoroutineStart.ATOMIC) {
+                expect(2)
+                yield()
+                expectUnreached()
+            }
+        }.join()
+        finish(3)
+    }
+
+
+    @Test
+    fun testCancelledWithContextUnconfined() = runTest {
+        val parent = Job()
+        launch(parent) {
+            expect(1)
+            parent.cancel()
+            withContext(Dispatchers.Unconfined) {
+                expectUnreached()
+            }
+        }.join()
+        finish(2)
+    }
+}
+\ No newline at end of file