From e5ca1275d419bd249f36e7f20925d07849a37972 Mon Sep 17 00:00:00 2001
From: Trask Stalnaker <trask.stalnaker@gmail.com>
Date: Fri, 10 Dec 2021 13:29:40 -0800
Subject: [PATCH] Fix kotlin coroutines test latest deps (#4873)

---
 .../javaagent/src/test/kotlin/KotlinCoroutineTests.kt        | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/instrumentation/kotlinx-coroutines/javaagent/src/test/kotlin/KotlinCoroutineTests.kt b/instrumentation/kotlinx-coroutines/javaagent/src/test/kotlin/KotlinCoroutineTests.kt
index 62196e1184..8e511908bd 100644
--- a/instrumentation/kotlinx-coroutines/javaagent/src/test/kotlin/KotlinCoroutineTests.kt
+++ b/instrumentation/kotlinx-coroutines/javaagent/src/test/kotlin/KotlinCoroutineTests.kt
@@ -17,6 +17,7 @@ import kotlinx.coroutines.channels.produce
 import kotlinx.coroutines.delay
 import kotlinx.coroutines.flow.collect
 import kotlinx.coroutines.flow.consumeAsFlow
+import kotlinx.coroutines.flow.onEach
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.runBlocking
 import kotlinx.coroutines.selects.select
@@ -37,9 +38,9 @@ class KotlinCoroutineTests(private val dispatcher: CoroutineDispatcher) {
       }
     }
 
-    producer.consumeAsFlow().collect {
+    producer.consumeAsFlow().onEach {
       tracedChild("consume_$it")
-    }
+    }.collect()
   }
 
   fun tracePreventedByCancellation() {