Fix compilation

qwwdfsad · qwwdfsad · commit 4095e6d8e6b2 · 2021-10-06T12:32:28.000+03:00
diff --git a/reactive/kotlinx-coroutines-rx2/test/ObservableMultiTest.kt b/reactive/kotlinx-coroutines-rx2/test/ObservableMultiTest.kt
@@ -51,7 +51,7 @@ class ObservableMultiTest : TestBase() {
     @Test
     fun testConcurrentStressOnSend() {
         val n = 10_000 * stressTestMultiplier
-        val observable = rxObservable {
+        val observable = rxObservable<Int> {
             newCoroutineContext(coroutineContext)
             // concurrent emitters (many coroutines)
             val jobs = List(n) {
diff --git a/reactive/kotlinx-coroutines-rx3/test/ObservableMultiTest.kt b/reactive/kotlinx-coroutines-rx3/test/ObservableMultiTest.kt
@@ -51,7 +51,7 @@ class ObservableMultiTest : TestBase() {
     @Test
     fun testConcurrentStressOnSend() {
         val n = 10_000 * stressTestMultiplier
-        val observable = rxObservable {
+        val observable = rxObservable<Int> {
             newCoroutineContext(coroutineContext)
             // concurrent emitters (many coroutines)
             val jobs = List(n) {
