Add an integration test for calling runBlocking from Java

Author: dkhalanskyjb

integration-testing/build.gradle.kts

@@ -134,6 +134,15 @@ sourceSets {
             implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:$coroutinesVersion")
         }
     }
+
+    create("javaConsumersTest") {
+        compileClasspath += sourceSets.test.get().runtimeClasspath
+        runtimeClasspath += sourceSets.test.get().runtimeClasspath
+
+        dependencies {
+            implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:$coroutinesVersion")
+        }
+    }
 }
 
 kotlin {
@@ -199,16 +208,23 @@ tasks {
         classpath = sourceSet.runtimeClasspath
     }
 
+    create<Test>("javaConsumersTest") {
+        val sourceSet = sourceSets[name]
+        testClassesDirs = sourceSet.output.classesDirs
+        classpath = sourceSet.runtimeClasspath
+    }
+
     check {
         dependsOn(
             "jvmCoreTest",
             "debugDynamicAgentTest",
             "mavenTest",
             "debugAgentTest",
             "coreAgentTest",
+            "javaConsumersTest",
             ":jpmsTest:check",
             "smokeTest:build",
-            "java8Test:check"
+            "java8Test:check",
         )
     }
 

integration-testing/src/javaConsumersTest/java/RunBlockingJavaTest.java

@@ -0,0 +1,20 @@
+import kotlinx.coroutines.BuildersKt;
+import kotlinx.coroutines.Dispatchers;
+import org.junit.Test;
+
+public class RunBlockingJavaTest {
+    Boolean entered = false;
+
+    /** This code will not compile if `runBlocking` doesn't declare `@Throws(InterruptedException::class)` */
+    @Test
+    public void testRunBlocking() {
+        try {
+            BuildersKt.runBlocking(Dispatchers.getIO(), (scope, continuation) -> {
+                entered = true;
+                return null;
+            });
+        } catch (InterruptedException e) {
+        }
+        assert entered;
+    }
+}

kotlinx-coroutines-core/jvm/test-resources/stacktraces/channels/testSendToChannel.txt

@@ -17,6 +17,5 @@ Caused by: java.util.concurrent.CancellationException: Channel was cancelled
 	at kotlinx.coroutines.BlockingCoroutine.joinBlocking(Builders.kt)
 	at kotlinx.coroutines.BuildersKt__BuildersKt.runBlockingImpl(Builders.kt)
 	at kotlinx.coroutines.BuildersKt.runBlockingImpl(Unknown Source)
-	at kotlinx.coroutines.BuildersKt__Builders_concurrentKt.runBlocking(Builders.concurrent.kt)
-	at kotlinx.coroutines.BuildersKt.runBlocking(Unknown Source)
+	at kotlinx.coroutines.Builders_concurrentKt.runBlocking(Builders.concurrent.kt)
 	at kotlinx.coroutines.testing.TestBase.runTest(TestBase.kt)