schedule.kt

package com.bnppf.easybanking

import arrow.fx.coroutines.Schedule
import io.kotest.core.spec.style.StringSpec
import kotlin.time.Duration.Companion.seconds
import kotlin.time.ExperimentalTime
import kotlin.time.TimeMark
import kotlin.time.TimeSource

@OptIn(ExperimentalTime::class)
class ScheduleFx : StringSpec({
    "test schedule" {
        val mark = TimeSource.Monotonic.markNow()
        var counter = 0
        val a = Schedule
            .spaced<Unit>(2.seconds)
            .untilInput<Unit> { mark.elapsedNow() > 10.seconds }
            .whileInput<Unit> { input -> counter < 100 }
            .logOutput { println("hello $it ${mark.elapsedNow()}") }
            .repeatOrElseEither({
                counter++
            }, { throwable, output ->
                throwable
            })

        println(a)
    }
})