Fix kotlin coroutines test latest deps (open-telemetry#4873)

RashmiRam · May 23, 2022 · 571aadc · 571aadc
1 parent 595763e
commit 571aadc
Showing 1 changed file with 3 additions and 2 deletions.
diff --git 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() {