pub async fn run( config: Config, event_tx: EventBroadcast, cancel: CancellationToken, ) -> Result<()>