node module: inject and compose through streams into a pipeline