Function create_stream_source_generator

pub(crate) fn create_stream_source_generator(
    stream_source: StreamSource,
    args: &Args,
) -> Box<dyn StreamSourceGenerator>