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