Trait AsyncTransformAdvanced 

pub trait AsyncTransformAdvanced<X, Output = X> {
    type Error: Error + Send + Sync;

    // Required methods
    fn transform_async_with_progress<'a>(
        &'a self,
        x: &'a X,
        config: &'a AsyncConfig,
    ) -> Pin<Box<dyn Future<Output = Result<Output>> + Send + 'a>>;
    fn transform_stream<'a>(
        &'a self,
        x_stream: Pin<Box<dyn Stream<Item = X> + Send + 'a>>,
        config: &'a AsyncConfig,
    ) -> Pin<Box<dyn Stream<Item = Result<Output>> + Send + 'a>>;
    fn transform_async_chunked<'a>(
        &'a self,
        x: &'a X,
        chunk_size: usize,
    ) -> Pin<Box<dyn Stream<Item = Result<Output>> + Send + 'a>>;
}

Enhanced async transform trait with streaming support

Required Associated Types

type Error: Error + Send + Sync

Error type

Required Methods

fn transform_async_with_progress<'a>( &'a self, x: &'a X, config: &'a AsyncConfig, ) -> Pin<Box<dyn Future<Output = Result<Output>> + Send + 'a>>

Transform data asynchronously with progress tracking

fn transform_stream<'a>( &'a self, x_stream: Pin<Box<dyn Stream<Item = X> + Send + 'a>>, config: &'a AsyncConfig, ) -> Pin<Box<dyn Stream<Item = Result<Output>> + Send + 'a>>

Stream data transformation

fn transform_async_chunked<'a>( &'a self, x: &'a X, chunk_size: usize, ) -> Pin<Box<dyn Stream<Item = Result<Output>> + Send + 'a>>

Transform with memory-efficient chunking

Implementors