Link to this section Summary

Types

args()

callback()

options()

reducer()

result()

Returns a list of functions to be used as callbacks of a pipeline. These callbacks will be executed in the same order that they appear on this list.

__pipeline_steps__()

Returns a list of functions to be used as steps of a pipeline. These steps will be executed in the same order that they appear on this list.

Executes the pipeline defined by module with the given value and options.

@type args() :: any()

@type callback() :: (Pipeline.State.t(), options() -> any())

@type options() :: Keyword.t()

@type reducer() :: (args(), options() -> result())

@type result() :: {:ok, any()} | {:error, any()}

@callback __pipeline_callbacks__() :: [callback()]

Returns a list of functions to be used as callbacks of a pipeline. These callbacks will be executed in the same order that they appear on this list.

@callback __pipeline_steps__() :: [reducer()]

Returns a list of functions to be used as steps of a pipeline. These steps will be executed in the same order that they appear on this list.

Executes the pipeline defined by module with the given value and options.