Pipeline

Apply the callback if the given "value" is (or resolves to) truthy.

Apply the callback if the given "value" is (or resolves to) falsy.

Register a custom macro.

Macros persist in a static property for the worker lifetime and apply to every subsequent call on the macroable class.

Mix another object into the class.

Delegates to macro() for each method; registered macros persist in a static property for the worker lifetime.

Check if macro is registered.

Flush the existing macros.

Clears worker-wide macros; concurrent coroutines may resolve different methods depending on timing.

Dynamically handle calls to the class.

Dynamically handle calls to the class.

Create a new class instance.

Set the object being sent through the pipeline.

Set the array of pipes.

Push additional pipes onto the pipeline.

Set the method to call on the pipes.

Run the pipeline with a final destination callback.

Create a reusable closure that receives a value on each invocation.

Class middleware resolves inside each call using its container lifetime. Supplied middleware objects and captured closure state remain shared. Transaction and finally callbacks are applied per invocation. Keep this pipeline's configuration unchanged while using the closure.

Run the pipeline and return the result.

Set a final callback to be executed after the pipeline ends regardless of the outcome.

Get the final piece of the Closure onion.

Get a Closure that represents a slice of the application onion.

Parse full pipe string to get name and parameters.

Get the array of configured pipes.

Execute each pipeline step within a database transaction.

Get the container instance.

Set the container instance.

Handle the value returned from each pipe before passing it to the next.

Handle the given exception.

Flush all static state.