Struct PipelineBuilder 

pub struct PipelineBuilder { /* private fields */ }

Implementations

impl PipelineBuilder

pub fn new(id: impl Into<String>) -> Self

pub fn add_source<S: SourceElement + 'static>( self, source: S, wire: impl FnOnce(&mut S, &Arc<Context>) -> Result<()>, ) -> Result<Self>

Registers one more source. wire receives a source-scoped Context; build detached branches with Context::branch and commit them with Context::attach. A wiring error aborts the builder without publishing a partially built pipeline.

pub fn build(self) -> Arc<Pipeline>

Finishes construction. At least one PipelineBuilder::add_source call must have happened — an empty Pipeline has nothing for Pipeline::run to ever drive, and Pipeline::bus would block forever waiting for a source thread that will never start (nothing left holding a Bus sender to eventually drop).