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