Aquascape describing `parEvalMapUnordered` and chunk preservation semantics.

parEvalMapUnorderedChunks.scala

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

import fs2.*
import cats.effect.*
import aquascape.*
import cats.syntax.all.*

object App extends AquascapeApp {

  def name: String = "aquascape"
  override def chunked: Boolean = true

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