chenharryhua/parEval.scala

## parEval.scala
  val zoneId = ZoneId.systemDefault()
  def timing(i: Int): IO[Unit] =
    IO.realTimeInstant.flatMap { start =>
      IO.sleep(i.seconds) >> IO.realTimeInstant.flatMap { end =>
        IO.println(s"$i ${start.atZone(zoneId).toLocalTime} ${end.atZone(zoneId).toLocalTime}")
      }
    }

  def run: IO[Unit] =
    Stream
      .range(9, 0, -1)
      .covary[IO]
      .parEvalMap(2)(i => timing(i).as(i))
      .evalTap(IO.println)
      .compile
      .drain
      .timed
      .flatMap(x => IO.println(x._1.toSeconds))
	val zoneId = ZoneId.systemDefault()
	def timing(i: Int): IO[Unit] =
	IO.realTimeInstant.flatMap { start =>
	IO.sleep(i.seconds) >> IO.realTimeInstant.flatMap { end =>
	IO.println(s"$i ${start.atZone(zoneId).toLocalTime} ${end.atZone(zoneId).toLocalTime}")
	}
	}

	def run: IO[Unit] =
	Stream
	.range(9, 0, -1)
	.covary[IO]
	.parEvalMap(2)(i => timing(i).as(i))
	.evalTap(IO.println)
	.compile
	.drain
	.timed
	.flatMap(x => IO.println(x._1.toSeconds))
No results found