Skip to main content

run_due_pass

Function run_due_pass 

Source
pub async fn run_due_pass<Context, Queue, BuildContext, BuildFuture>(
    queue: &Queue,
    registry: &DriverRegistry<Context>,
    settings: &SupervisorSettings,
    build_context: BuildContext,
) -> Result<SupervisorStats, String>
where Context: Send + Sync + 'static, Queue: WorkQueue, BuildContext: FnOnce() -> BuildFuture, BuildFuture: Future<Output = Result<Context, String>> + Send,