Fix

typelevel · Aug 3, 2023 · 4d8279b · 4d8279b
1 parent 6d0dc50
commit 4d8279b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tests/shared/src/test/scala/cats/effect/std/QueueSpec.scala b/tests/shared/src/test/scala/cats/effect/std/QueueSpec.scala
@@ -278,7 +278,7 @@ class BoundedQueueSpec extends BaseSpec with QueueTests[Queue] with DetectPlatfo
         q <- constructor(64)
 
         produce = 0.until(fiberCount).toList.parTraverse_(producer(q, _))
-        consume = 0.until(fiberCount).toList.parTraverse(consumer(q, _)).map(_.flatten)
+        consume = 0.until(fiberCount).toList.parTraverse(consumer(q, _)).map(_.flatMap(identity))
 
         results <- produce &> consume