ZIO learning - garbage collected fibers / published by https://github.com/dacr/code-examples-manager #13f4a62f-c2ec-4405-a710-1444844f1592/dbaecd49a23c9065937426795454356c5e159d38

zio-learning-16-garbage-collected-fibers.sc

// summary : ZIO learning - garbage collected fibers
// keywords : scala, zio, learning, pure-functional, @testable
// publish : gist
// authors : David Crosson
// license : Apache NON-AI License Version 2.0 (https://raw.githubusercontent.com/non-ai-licenses/non-ai-licenses/main/NON-AI-APACHE2)
// id : 13f4a62f-c2ec-4405-a710-1444844f1592
// created-on : 2021-04-06T09:46:48+02:00
// managed-by : https://github.com/dacr/code-examples-manager
// run-with : scala-cli $file

// ---------------------
//> using scala "3.4.2"
//> using dep "dev.zio::zio:2.0.13"
// ---------------------

/*
 inspired from
   - [John A De Goes - ZIO: Next-Generation Effects in Scala](https://www.youtube.com/watch?v=mkSHhsJXjdc)
   - +23:30
 */

import zio.*

object Encapsulated extends ZIOAppDefault {
  val logic = for {
    queue <- Queue.bounded[Int](100)
    fiber <- queue.take.flatMap(v => Console.printLine(s"$v ")).forever.fork
    _     <- ZIO.foreach(0 to 100)(queue.offer(_)).forever
  } yield ()

  def run = logic.timeout(Duration.fromMillis(5000)) // Just to avoid this script to run infinitly...
}
// infinitely running fiber... which will be garbage collected
// (unlike threads which required to be stopped !)

// -------------------------------------------------------------
Encapsulated.main(Array.empty)