ProcessFork.scala

object Main extends SafeApp {
  def handleEvent(i: Int) =
    Task.delay {
      Task.fork(Task.delay {
        println(i)
        Thread.sleep(1000)
      }).runAsync(_ => ())
    }

  override def run(args: ImmutableArray[String]) = IO {
    val p = Process.constant[Int](100).take(3)
    p.evalMap(handleEvent).run.run
  }
}