Aquascape describing `evalTap` followed by `parEvalMapUnordered`.

evalTapThenparEvalMapUnordered.scala

//> using scala "3.5.0"
//> using dep "com.github.zainab-ali::aquascape::0.3.0"

import fs2.*
import cats.effect.*
import aquascape.*
import cats.syntax.all.*
import scala.concurrent.duration.*

object App extends AquascapeApp {

  def name: String = "aquascape"
  def process(c: Char): IO[Unit] = IO.sleep(1.second)
  override def chunked: Boolean = true

  def stream(using Scape[IO]) = {
    Stream('a', 'b', 'c')
      .covary[IO]
      .stage("Stream('a','b','c')", "upstream")
      .evalTap(process)
      .stage("evalTap(process)", "upstream")
      .fork("root", "upstream")
      .parEvalMapUnordered(3)(c => c.pure[IO].trace())
      .stage("parEvalMapUnordered(3)(…)")
      .compile
      .drain
      .compileStage("compile.drain")
  }
}