pub trait Runner { // Required method fn run(&self, config: Config) -> Result<StreamReceiver, Error>; }