Struct FnBehavior 

pub struct FnBehavior<F> { /* private fields */ }

Implementations

impl<F> FnBehavior<F>

pub fn new(id: BehaviorId, pattern: EventPattern, f: F) -> Self

Examples found in repository

examples/behavior_subscription.rs (lines 12-31)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let state = YoAgentState::load(MemoryEventStore::new()).await?;
    let mut runtime = YoAgentRuntime::new(state.clone());

    runtime.register_behavior(FnBehavior::new(
        BehaviorId::new("behavior_failure_to_task"),
        EventPattern::Kind("failure.observed".to_string()),
        |_ctx: BehaviorContext, event: Event| async move {
            let title = event
                .payload
                .get("title")
                .and_then(|value| value.as_str())
                .unwrap_or("Investigate failure");
            Ok(vec![StateOp::CreateNode {
                id: NodeId::new("task_from_failure"),
                kind: "task".to_string(),
                props: json!({
                    "title": format!("Investigate: {title}"),
                    "status": "Open",
                    "created_by_behavior": "behavior_failure_to_task",
                }),
            }])
        },
    ));

    runtime
        .emit_event(Event::new(
            ActorRef::agent("demo"),
            "failure.observed",
            json!({ "title": "retry timeout loses state" }),
        ))
        .await?;

    print!(
        "{}",
        state
            .lineage(NodeId::new("task_from_failure"))
            .await
            .to_markdown()
    );
    Ok(())
}

Trait Implementations

impl<F, Fut> Behavior for FnBehavior<F>

where F: Send + Sync + Fn(BehaviorContext, Event) -> Fut, Fut: Send + Future<Output = Result<Vec<StateOp>, StateError>>,

fn id(&self) -> BehaviorId

fn pattern(&self) -> EventPattern

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, ctx: BehaviorContext, event: &'life1 Event, ) -> Pin<Box<dyn Future<Output = Result<Vec<StateOp>, StateError>> + Send + 'async_trait>>

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