1 files changed, 41 insertions, 0 deletions
diff --git a/kotlinx-coroutines-core/jvm/test/ReusableContinuationStressTest.kt b/kotlinx-coroutines-core/jvm/test/ReusableContinuationStressTest.kt
new file mode 100644
index 00000000..a256815d
--- /dev/null
+++ b/kotlinx-coroutines-core/jvm/test/ReusableContinuationStressTest.kt
@@ -0,0 +1,41 @@
+/*
+ * Copyright 2016-2021 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+package kotlinx.coroutines
+
+import kotlinx.coroutines.flow.*
+import org.junit.*
+
+class ReusableContinuationStressTest : TestBase() {
+
+    private val iterations = 1000 * stressTestMultiplierSqrt
+
+    @Test // Originally reported by @denis-bezrukov in #2736
+    fun testDebounceWithStateFlow() = runBlocking<Unit> {
+        withContext(Dispatchers.Default) {
+            repeat(iterations) {
+                launch { // <- load the dispatcher and OS scheduler
+                    runStressTestOnce(1, 1)
+                }
+            }
+        }
+    }
+
+    private suspend fun runStressTestOnce(delay: Int, debounce: Int) = coroutineScope {
+        val stateFlow = MutableStateFlow(0)
+        val emitter = launch {
+            repeat(1000) { i ->
+                stateFlow.emit(i)
+                delay(delay.toLong())
+            }
+        }
+        var last = 0
+        stateFlow.debounce(debounce.toLong()).take(100).collect { i ->
+            if (i - last > 100) {
+                last = i
+            }
+        }
+        emitter.cancel()
+    }
+}