pub(crate) async fn run_driver_service( stream: ValidateRequestStream, publisher: Publisher ) -> Result<(), Error>