Struct BufferedPipeline 

pub struct BufferedPipeline<T: 'static> { /* private fields */ }

Pipeline variant using FabricQueue inter-stage buffering.

Materializes a FabricQueue at each stage boundary, proving the integration with grafos-collections. Items are serialized into the queue by the producer and deserialized by the consumer.

Implementations

impl<T: Serialize + DeserializeOwned + 'static> BufferedPipeline<T>

pub fn new( source: impl Source<T> + 'static, stages: Vec<StageEntry>, capacity: usize, stride: usize, ) -> Self

Create a buffered pipeline that uses FabricQueues between stages.

pub fn run(&mut self) -> Result<Vec<T>, FabricError>

Run the pipeline using FabricQueues for inter-stage buffering.

Each stage boundary creates a FabricQueue, pushes items in, applies the transform, and collects the output.