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