Trait stream_processor_test::StreamProcessorFactory

pub trait StreamProcessorFactory {
    // Required method
    fn connect_to_stream_processor(
        &self,
        stream: &dyn ElementaryStream,
        format_details_version_ordinal: u64,
    ) -> BoxFuture<'_, Result<StreamProcessorProxy>>;
}

Required Methods

fn connect_to_stream_processor( &self, stream: &dyn ElementaryStream, format_details_version_ordinal: u64, ) -> BoxFuture<'_, Result<StreamProcessorProxy>>

Implementors