arrow-resilience/arrow.resilience/Schedule/Decision/Continue

Continue

data class Continue<in Input, out Output>(val output: Output, val delay: Duration, val step: ScheduleStep<Input, Output>) : Schedule.Decision<Input, Output> (source)

Constructors

constructor(output: Output, delay: Duration, step: ScheduleStep<Input, Output>)

Properties

val delay: Duration

open override val output: Output

val step: ScheduleStep<Input, Output>

Functions

open suspend fun <B, C> and(other: Schedule.Decision<Input, B>, transform: suspend (output: Output, b: B) -> C, combineDuration: suspend (left: Duration, right: Duration) -> Duration): Schedule.Decision<Input, C>

open suspend fun andThen(other: suspend (Input) -> Schedule.Decision<Input, Output>): Schedule.Decision<Input, Output>

open suspend fun <A, B> andThen(other: suspend (Input) -> Schedule.Decision<Input, A>, ifLeft: suspend (Output) -> B, ifRight: suspend (A) -> B): Schedule.Decision<Input, B>

open suspend fun <A> contramap(f: suspend (A) -> Input): Schedule.Decision<A, Output>

open suspend fun delayed(transform: suspend (Output, Duration) -> Duration): Schedule.Decision<Input, Output>

open suspend fun <A> map(f: suspend (output: Output) -> A): Schedule.Decision<Input, A>

open suspend fun <B, C> or(other: Schedule.Decision<Input, B>, transform: suspend (output: Output?, b: B?) -> C, combineDuration: suspend (left: Duration?, right: Duration?) -> Duration): Schedule.Decision<Input, C>

open suspend fun recursiveMap(transform: suspend (Schedule.Decision<Input, Output>) -> Schedule.Decision<Input, Output>): Schedule.Decision<Input, Output>