Struct Context 

pub struct Context { /* private fields */ }

A lightweight context for inline codegen that avoids the overhead of the full scheduled graph (no tokio channels, no scheduler queues, no loop machinery).

Exposes methods that operator-generated code calls on both df (for prologues: request_task) and context (for iterators: current_tick, schedule_subgraph, etc.).

Implementations

impl Context

pub fn new(wake_state: Arc<WakeState>, metrics: Rc<DfirMetrics>) -> Self

Create a new inline context with shared wake state and metrics.

pub fn request_task<Fut>(&mut self, future: Fut)

where Fut: Future<Output = ()> + 'static,

Available on crate feature tokio only.

Buffers an async task to be spawned later by Dfir::spawn_tasks.

Tasks are deferred because write_prologue runs during graph construction, which may occur before a tokio LocalSet is entered. Buffered tasks are drained and spawned via tokio::task::spawn_local at the start of Dfir::run_tick. Tasks requested after that point remain buffered until the next call to Dfir::run_tick.

pub fn current_tick(&self) -> TickInstant

Gets the current tick count.

pub fn metrics(&self) -> &Rc<DfirMetrics>

Returns a reference to the runtime metrics.

pub fn schedule_subgraph(&self, is_external: bool)

Signals that external data has arrived and a new tick should be started.

pub fn waker(&self) -> Waker

Returns a waker that signals external data has arrived.

Trait Implementations

impl Default for Context

fn default() -> Context

Returns the “default value” for a type.