Struct SimpleAgentRunner 

pub struct SimpleAgentRunner { /* private fields */ }

Implementations

impl SimpleAgentRunner

pub fn new(agent: impl Agent + 'static) -> Self

Examples found in repository

examples/agent_example.rs (line 21)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("=== Rust Agent v0.0.1 - Agent使用示例 ===");
    
    // 创建一个简单的Agent
    let mut agent = SimpleAgent::new();
    
    // 添加一些示例工具
    let weather_tool = Box::new(ExampleTool::new(
        "get_weather".to_string(),
        "获取指定城市的天气信息".to_string(),
    ));
    
    agent.add_tool(weather_tool);
    
    // 创建Agent运行器
    let agent_runner = SimpleAgentRunner::new(agent);
    
    // 测试调用工具
    println!("\n1. 测试调用工具:");
    test_tool_invocation(&agent_runner).await?;
    
    // 测试直接完成
    println!("\n2. 测试直接完成:");
    test_direct_completion(&agent_runner).await?;
    
    println!("\n示例完成！");
    Ok(())
}

Trait Implementations

impl Runnable<HashMap<String, String>, AgentOutput> for SimpleAgentRunner

fn invoke( &self, inputs: HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = Result<AgentOutput, Error>> + Send>>

fn clone_to_owned( &self, ) -> Box<dyn Runnable<HashMap<String, String>, AgentOutput> + Send + Sync>

fn invoke_with_config( &self, input: I, _config: Option<HashMap<String, Value>>, ) -> Pin<Box<dyn Future<Output = Result<O, Error>> + Send>>

fn batch( &self, inputs: Vec<I>, ) -> Pin<Box<dyn Future<Output = Vec<Result<O, Error>>> + Send>>

fn batch_with_config( &self, inputs: Vec<I>, _config: Option<HashMap<String, Value>>, ) -> Pin<Box<dyn Future<Output = Vec<Result<O, Error>>> + Send>>

fn stream(&self, input: I) -> Box<dyn Stream<Item = Result<O, Error>> + Send>

fn astream( &self, _input: I, ) -> Pin<Box<dyn Future<Output = Box<dyn Stream<Item = Result<O, Error>> + Send>> + Send>>