Struct LiveEffectExecutor 

pub struct LiveEffectExecutor { /* private fields */ }

Executes LiveEffect values emitted by the Live reactor.

Implementations

impl LiveEffectExecutor

pub fn new( writer: Arc<dyn SessionWriter>, pending_context: Option<Arc<PendingContext>>, event_tx: Sender<LiveEvent>, ) -> LiveEffectExecutor

Create an executor backed by a session writer.

pub async fn execute_reactions( &self, reactions: Vec<Reaction>, ) -> Result<(), SessionError>

Execute a list of policy-wrapped reactions.

pub async fn execute(&self, effect: LiveEffect) -> Result<(), SessionError>

Execute one typed effect.

pub async fn flush_deferred_prompt(&self) -> Result<(), SessionError>

Flush deferred context and an armed prompt.

This is intentionally gated by PendingContext::take_prompt, so a playback-drained event cannot trigger a new empty model turn unless the control plane explicitly armed one.

Trait Implementations

impl Clone for LiveEffectExecutor

fn clone(&self) -> LiveEffectExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.