Struct CompiledGraphEngine 

pub struct CompiledGraphEngine<T: Transcendental, const BUF_SIZE: usize> { /* private fields */ }

Graph execution engine running a CompiledGraph.

Implementations

impl<T: Transcendental, const BUF_SIZE: usize> CompiledGraphEngine<T, BUF_SIZE>

pub fn new( graph: CompiledGraph<T, BUF_SIZE>, mailbox: Arc<Mailbox<CommandEnum>>, ) -> Self

Create a new graph engine from a compiled graph and a shared mailbox.

pub fn handle(&self) -> ActorRef<CommandEnum>

Returns the actor handle for sending control commands to the engine.

pub fn param_map(&self) -> HashMap<String, usize>

Returns the merged parameter map for all nodes in the engine.

The map is the first node’s mapping, which covers all parameters for single-node engines. For multi-node graphs, this returns the first node’s map only.

pub fn apply_due_params(&mut self, chunk_end: u64)

Apply pending parameter updates that are due by chunk_end. Preserves sample-accurate scheduling: params with sample_pos >= chunk_end are deferred to the next tick.

pub fn process_tick( &mut self, inputs: &[&[T]], outputs: &mut [&mut [T]], chunk_end: u64, ) -> ProcessResult<()>

Main processing tick — applies pending params, copies inputs, runs nodes, copies outputs.

pub fn reset(&mut self)

Reset all buffers and nodes to initial state.

Trait Implementations

impl<T: Transcendental, const BUF_SIZE: usize> Algorithm<T> for CompiledGraphEngine<T, BUF_SIZE>

fn process( &mut self, input: Option<&[T]>, output: &mut [T], ) -> ProcessResult<()>

Process one block of signal.

fn reset(&mut self)

Reset the algorithm to its initial state.

fn apply_command(&mut self, _value: T)

Receive a real-time command value from the control path.

fn init(&mut self, _sample_rate: f32)

Initialise the algorithm with a sample rate.

fn metadata(&self) -> AlgorithmMetadata

Descriptive metadata (defaults to empty).

impl<T: Transcendental, const BUF_SIZE: usize> MultichannelAlgorithm<T> for CompiledGraphEngine<T, BUF_SIZE>

fn num_inputs(&self) -> usize

Number of signal input channels.

fn num_outputs(&self) -> usize

Number of signal output channels.

fn process( &mut self, inputs: &[&[T]], outputs: &mut [&mut [T]], ) -> ProcessResult<()>

Process one buffer of samples.

fn reset(&mut self)

Reset internal state.