ZIO queue example

ZioQueuePullPush.scala

import zio._
import zio.console._
import zio.stream._
import zio.duration._

object ZioQueuePullPush extends zio.App {

  // c.f. ZIO type aliases https://zio.dev/docs/overview/overview_index#type-aliases
  val result: URIO[Clock with Console, Unit] = for {
    queue <- Queue.bounded[Int](100)
    consumeQueue = ZStream.fromQueue(queue).foreach(e => putStrLn(e.toString))
    //Sleep without blocking threads thanks to ZIO fibers
    feedQueue = ZIO.foreach(Range(1,1000))(e => ZIO.sleep(10.millis) *> queue.offer(e))
    //run consume and feed in parallel
    _ <- consumeQueue.zipPar(feedQueue)
  } yield ()

  override def run(args: List[String]) = result.map(_ => 1)
  /* output :
  1
  2
  3
  ...
  999
  */

}