Create the pipeline by creating an ff_pipe object and passing as parameters the stages:

ff_pipe<T> myPipe(stage1, stage2, ...) 

T is the type of the taks flowing throuhg the pipeline.

The pipeline stages should be procedures/lambdas with signature

T* f(T*, ff_node*)

The second parameter is used by the implementation.