Skip to content

Commit

Permalink
Formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
armanbilge committed Aug 3, 2023
1 parent 4d8279b commit 27c7bba
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion tests/shared/src/test/scala/cats/effect/std/QueueSpec.scala
Original file line number Diff line number Diff line change
Expand Up @@ -278,7 +278,11 @@ 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(_.flatMap(identity))
consume = 0
.until(fiberCount)
.toList
.parTraverse(consumer(q, _))
.map(_.flatMap(identity))

results <- produce &> consume

Expand Down

0 comments on commit 27c7bba

Please sign in to comment.