Function kafka_json_processor_core::simulation::simulate_streams

pub fn simulate_streams<P: AsRef<Path>>(
    streams: HashMap<String, Stream>,
    base_path: P
)