Pipeline

A monad abstraction that can be used to build up a chain of transformations of state. An input state can then be passed through the pipeline with the run method.

The state is queried for success via the trait StageResult.

If the state does not report as success after executing a stage, the rest of the pipeline is bypassed.

Code example

case class State(override val success: Boolean = true, value: Int = 0) extends SuccessState

val pipeline = for (
  _ <- Pipeline.Stage((a: State) => a.copy(value = a.value + 1));
  _ <- Pipeline.Stage((a: State) => a.copy(value = a.value + 10));
  finalState <- Pipeline.Stage((a: State) => a.copy(value = a.value + 100))
) yield finalState

println(pipeline.run(State()))
// Will print State(true,111)