Trait StreamingTransform 

pub trait StreamingTransform<S, Output> {
    type Error: Error + Send + Sync;

    // Required method
    fn transform_stream<'a>(
        &'a self,
        stream: S,
    ) -> Pin<Box<dyn Stream<Item = Result<Output>> + Send + 'a>>
       where S: Stream + Send + 'a;
}

Trait for streaming transformations

Required Associated Types

type Error: Error + Send + Sync

Required Methods

fn transform_stream<'a>( &'a self, stream: S, ) -> Pin<Box<dyn Stream<Item = Result<Output>> + Send + 'a>>

where S: Stream + Send + 'a,

Transform streaming data

Implementors