ZIO Cron

Cron scheduler for ZIO 1 and ZIO 2 inspired by cron4zio.

It uses cron-utils to define cron and calculate next run. Please take a look at repository to find out how to define and parse cron expressions.

SBT

ZIO1

libraryDependencies += "io.github.jkobejs" %% "zio1-cron" % "x.x.x"

ZIO2

libraryDependencies += "io.github.jkobejs" %% "zio-cron" % "x.x.x"

Example

import com.cronutils.model.CronType
import com.cronutils.model.definition.CronDefinitionBuilder
import com.cronutils.parser.CronParser
import io.github.jkobejs.cron.syntax.CronOps
import zio.{Clock, Console, ZIO, ZIOAppDefault}

object Main extends ZIOAppDefault {
  def run = {
    val zio = for {
      currentTime <- Clock.localDateTime
      _ <- Console.printLine(s"${currentTime.toString}")
    } yield ()

    val parser = new CronParser(CronDefinitionBuilder.instanceDefinitionFor(CronType.QUARTZ))

    for {
      // every 2 seconds in this year
      cron <- ZIO.attempt(parser.parse("*/2 * * * * ? 2022"))
      runs <- zio.repeatWithCron(cron)
      _ <- Console.printLine(s"Total runs: $runs")
    } yield ()
  }
}