Function run_schema_validator 

async fn run_schema_validator(
    tx: UnboundedSender<SchemaValidationError>,
    interval: impl Fn() -> Duration,
    validate: impl AsyncFnMut() -> Vec<SchemaValidationError>,
)

Runs validate once per interval and sends each failure to tx once.

Stops after the first failure that ends the whole source, or once the receiver is dropped.