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