Refactor: no lambda for PipelineEmitter
Throw exception if no observers found
Reformat