Skip to main content

DeferredOperator

Type Alias DeferredOperator 

Source
pub type DeferredOperator = Box<dyn FnOnce(u32, &[(u32, u32)]) -> Result<Box<dyn Operator>, String> + Send>;
Expand description

An operator built once its task’s input edges are known: (task id, in-edges with the upstream task each comes from) — a two-input operator learns which edges are which side. Err when it cannot be built (a checkpoint it refuses to restore): the whole start fails, before any task runs, with that message.

Aliased Type§

pub struct DeferredOperator(/* private fields */);