2.0.0

arrow-resilience/arrow.resilience/Schedule/Decision

Decision

sealed interface Decision<in Input, out Output>

Inheritors

Types

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

data class Done<out Output>(val output: Output) : Schedule.Decision<Any?, Output>

Properties

abstract val output: 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>