Railway Flow-Based Programming

Absctraction to call the pipeline

Consumes the pipeline data

Defines internal pipeline struct

Defines macros for pipeline creating

Defines functions to start and to stop a pipeline

Pushes data to pipeline

Pipes function is called here

Pipeline supevisor

Sync pipeline supevisor