Struct AgentFlow 

pub struct AgentFlow<A: Agent> { /* private fields */ }

Adapter wrapping a concrete Agent into a Flow by JSON-marshalling at the I/O boundary.

This is parameterised on a concrete A: Agent + 'static, not dyn Agent — the latter is impossible because Agent has associated types. Each AgentFlow<A> is a distinct type, but each implements Flow so callers can hold them as Arc<dyn Flow>.

Implementations

impl<A: Agent + 'static> AgentFlow<A>

pub fn new(agent: A) -> Self

Wrap an agent so it can participate in flows.

pub fn from_arc(agent: Arc<A>) -> Self

Wrap an Arc<A> so the same agent can be referenced from multiple flows without cloning the underlying state.

Trait Implementations

impl<A: Agent + 'static> Flow for AgentFlow<A>

fn name(&self) -> &str

Stable flow name. Used in tracing spans.

fn run<'life0, 'async_trait>( &'life0 self, ctx: AgentContext, input: Value, ) -> Pin<Box<dyn Future<Output = Result<Value, FlowError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the flow once.