Struct AgentContinuation 

pub struct AgentContinuation<E, M: Model<E>> { /* private fields */ }

Implementations

impl<E: 'static, M: Model<E> + 'static> AgentContinuation<E, M>

pub fn new<F>(to_event_payload: F) -> Self

where F: Fn(AgentContinuation<E, M>) -> E + 'static,

Creates a new AgentContinuation instance.

Arguments

• to_event_payload - A closure that defines how to transform the continuation into an event payload for scheduling the next step.

pub fn then_after<F>( self, tag: &'static str, delay: Duration, priority: EventPriority, logic: F, ) -> Self

where F: FnOnce(&mut EventContext<E, M>, &mut M, &mut VecDeque<AgentStep<E, M>>) + 'static,

Appends a new step to be executed after the specified delay.

Arguments

• tag - A descriptive label for the step, useful for debugging and tracking.
• delay - The time duration to wait before executing this step.
• priority - The priority of the event within the event scheduler.
• logic - The closure containing the logic to be executed for this step.

impl<E, M: Model<E>> AgentContinuation<E, M>

pub fn peek_next_step(&self) -> Option<&AgentStep<E, M>>

Returns a reference to the next step scheduled to be executed, without consuming it.

pub fn peek_next_step_tag(&self) -> Option<&'static str>

Returns the tag of the next scheduled step, if available.

pub fn get_remain_step_count(&self) -> usize

Returns the total number of steps remaining in the continuation.

pub fn execute_and_schedule( self, context: &mut EventContext<E, M>, model: &mut M, )

Consumes and executes the current step, then schedules the next step if one exists. If no further steps remain, the continuation concludes gracefully.

Trait Implementations

impl<E, M: Model<E>> Debug for AgentContinuation<E, M>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.