Struct ExecutorCapacityWaitRegistration 

pub struct ExecutorCapacityWaitRegistration { /* private fields */ }

Type-erased, single-use registration for one plan-runtime capacity wait.

Registration is created synchronously so the executor can subscribe before the engine releases its iteration lock. Awaiting it never grants resources; it only returns fresh epochs that permit another authoritative admission probe.

Implementations

impl ExecutorCapacityWaitRegistration

pub fn new<F>(future: F) -> Self

where F: Future<Output = Result<ExecutorAdmissionEpochs>> + Send + 'static,

pub async fn wait_for_change(self) -> Result<ExecutorAdmissionEpochs>