pub fn run_processor(streams: HashMap<String, Stream>)