Struct AdvancedStreamPipeline 

pub struct AdvancedStreamPipeline { /* private fields */ }

Advanced streaming pipeline with memory optimization

Implementations

impl AdvancedStreamPipeline

pub fn new() -> Self

Create a new advanced-performance streaming pipeline

pub fn with_buffer_size(self, size: usize) -> Self

Set buffer size for inter-stage communication

Arguments

• size - Buffer size for channels

Returns

• Self for method chaining

pub fn with_num_threads(self, threads: usize) -> Self

Set number of worker threads

Arguments

• threads - Number of worker threads

Returns

• Self for method chaining

pub fn with_zero_copy(self) -> Self

Enable zero-copy processing with memory pooling

pub fn add_simd_stage<S: ProcessingStage>(self, stage: S) -> Self

Add a SIMD-optimized processing stage

pub fn process_advanced_stream<I>( &mut self, input: I, ) -> AdvancedStreamProcessor

where I: Iterator<Item = Frame> + Send + 'static,

Process stream with advanced-performance optimizations

pub fn memory_stats(&self) -> MemoryStats

Get current memory usage statistics

pub fn reset_memory_stats(&self)

Reset memory profiler statistics

pub fn metrics(&self) -> PipelineMetrics

Get current pipeline metrics

Trait Implementations

impl Default for AdvancedStreamPipeline

fn default() -> Self

Returns the “default value” for a type.