Modelling lazy infinite streams in Kyo 0.12.x (https://getkyo.io/#/?id=stream-composable-data-processing)

KyoPlayground.scala

import kyo.*
import kyo.Emit.Ack

object Playground extends KyoApp:
  def recursiveStream(start: Int): Stream[Int, IO] =
    def go(n: Int): Ack < Emit[Chunk[Int]] =
      Emit.andMap(Chunk(n)):
        case Ack.Stop        => Ack.Stop
        case Ack.Continue(_) => go(n + 1)

    Stream(go(start))

  run:
    val computation = recursiveStream(1).take(32).run
    for
      c <- computation
      _ <- IO(println(c))
    yield ()