Struct SequentialAgent 

pub struct SequentialAgent<P: LlmProvider> { /* private fields */ }

Runs a list of sub-agents in order. Each agent receives the previous agent’s text output as its task input. Returns the final agent’s output with accumulated TokenUsage.

Implementations

impl<P: LlmProvider> SequentialAgent<P>

pub fn builder() -> SequentialAgentBuilder<P>

Create a new SequentialAgentBuilder.

Add agents with .agent(...) in execution order; each agent receives the previous agent’s text output as its task input.

Example

use std::sync::Arc;
use heartbit_core::{
    AgentRunner, AnthropicProvider, BoxedProvider, SequentialAgent,
};

let provider = Arc::new(BoxedProvider::new(AnthropicProvider::new(
    "sk-...",
    "claude-sonnet-4-20250514",
)));
let researcher = AgentRunner::builder(provider.clone())
    .system_prompt("Summarize the topic in 3 bullet points.")
    .build()?;
let writer = AgentRunner::builder(provider)
    .system_prompt("Rewrite as a single engaging paragraph.")
    .build()?;

let pipeline = SequentialAgent::builder()
    .agent(researcher)
    .agent(writer)
    .build()?;
let output = pipeline.execute("History of Rust").await?;
println!("{}", output.result);

pub async fn execute(&self, task: &str) -> Result<AgentOutput, Error>

Execute the sequential pipeline, feeding each agent’s output as the next agent’s input.

Trait Implementations

impl<P: LlmProvider> Debug for SequentialAgent<P>

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

Formats the value using the given formatter.

impl<P: LlmProvider + 'static> From<SequentialAgent<P>> for WorkflowRouter<P>

fn from(agent: SequentialAgent<P>) -> Self

Converts to this type from the input type.