fix lint and tests

zio · Jun 13, 2024 · fe2f035 · fe2f035
1 parent 24e5f69
commit fe2f035
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/streams-tests/shared/src/test/scala/zio/stream/ZPipelineSpec.scala b/streams-tests/shared/src/test/scala/zio/stream/ZPipelineSpec.scala
@@ -50,13 +50,13 @@ object ZPipelineSpec extends ZIOBaseSpec {
  for {
  _ <- ZIO.debug("start")
  _ <- ZPipeline
- .mapZIOPar(2) { (i:Int) =>
+ .mapZIOPar(2) { i:Int =>
  processElement(i)
  }
  .apply(ZStream.iterate[Int](0)(_ + 1))
  .runDrain
  .zipParLeft(
- ZIO.debug("----").delay(2.seconds).forever
+ ZIO.debug("----").delay(2.seconds).repeatN(5)
  )
  } yield assertCompletes
  }
@@ -69,13 +69,13 @@ object ZPipelineSpec extends ZIOBaseSpec {
  for {
  _ <- ZIO.debug("start")
  _ <- ZPipeline
- .mapZIOParUnordered(2) { (i:Int) =>
+ .mapZIOParUnordered(2) { i:Int =>
  processElement(i)
  }
  .apply(ZStream.iterate[Int](0)(_ + 1))
  .runDrain
  .zipParLeft(
- ZIO.debug("----").delay(2.seconds).forever
+ ZIO.debug("----").delay(2.seconds).repeatN(5)
  )
  } yield assertCompletes
  }