aquascape: metered & parEvalMapUnorderedUnbounded

MeteredParEvalMapUnbounded.scala

//> using scala "3.7.0"
//> using dep "com.github.zainab-ali::aquascape::0.4.0"

import fs2.*
import cats.effect.*
import aquascape.*
import aquascape.drawing.*
import scala.concurrent.duration.*

object MeteredParEvalMapUnbounded extends AquascapeApp {
  override def config: Config = super.config.scale(4)
  def name: String = "aquascape"
  def stream(using Scape[IO]): IO[Unit] = {
    Stream('a', 'b', 'c', 'd')
      .stage("input", "upstream")
      .metered(1.second)
      .stage("metered(1s)", "upstream")
      .fork("root", "upstream")
      .parEvalMapUnorderedUnbounded(c => IO.sleep(3.seconds).as(c))
      .stage("parEvalMapUnorderedUnbounded(sleep(3s))")
      .compile
      .drain
      .compileStage("output")
      .void
  }
}

Run with scala-cli https://gist.github.com/zainab-ali/fb78a2b8173c9e1105a30a968c2209e9 and open aquscape.png:

Learn how to read he aquascapes.