pub(crate) fn create_stream_source_generators(
    args: &Args
) -> Box<dyn StreamSourceGenerator>