Enum Composable 

pub enum Composable {
    Agent(AgentBuilder),
    Pipeline(Pipeline),
    FanOut(FanOut),
    Loop(Loop),
    Fallback(Fallback),
}

A composable workflow node — can be sequenced, fan-out, looped, etc.

Variants

Agent(AgentBuilder)

A single agent node.

Pipeline(Pipeline)

A sequential pipeline of steps.

FanOut(FanOut)

A parallel fan-out of branches.

Loop(Loop)

A loop with optional termination predicate.

Fallback(Fallback)

A fallback chain (try each until one succeeds).

Implementations

impl Composable

pub fn compile(self, llm: Arc<dyn BaseLlm>) -> Arc<dyn TextAgent>

Compile this composable tree into an executable TextAgent.

Recursively compiles the tree: pipelines become SequentialTextAgent, fan-outs become ParallelTextAgent, loops become LoopTextAgent, fallbacks become FallbackTextAgent, and agents compile via AgentBuilder::build().

let pipeline = AgentBuilder::new("writer").instruction("Write a draft")
    >> AgentBuilder::new("reviewer").instruction("Review and improve");

let agent = pipeline.compile(llm);
let result = agent.run(&state).await?;

Trait Implementations

impl BitOr<AgentBuilder> for Composable

Composable | AgentBuilder → FanOut (flattening)

type Output = Composable

The resulting type after applying the | operator.

fn bitor(self, rhs: AgentBuilder) -> Self::Output

Performs the | operation.

impl BitOr for Composable

Composable | Composable → FanOut (flattening)

type Output = Composable

The resulting type after applying the | operator.

fn bitor(self, rhs: Composable) -> Self::Output

Performs the | operation.

impl Clone for Composable

fn clone(&self) -> Composable

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Composable

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

Formats the value using the given formatter.

impl Div<AgentBuilder> for Composable

Composable / AgentBuilder → Fallback (flattening)

type Output = Composable

The resulting type after applying the / operator.

fn div(self, rhs: AgentBuilder) -> Self::Output

Performs the / operation.

impl Div for Composable

Composable / Composable → Fallback (flattening)

type Output = Composable

The resulting type after applying the / operator.

fn div(self, rhs: Composable) -> Self::Output

Performs the / operation.

impl From<AgentBuilder> for Composable

fn from(b: AgentBuilder) -> Self

Converts to this type from the input type.

impl From<Fallback> for Composable

fn from(f: Fallback) -> Self

Converts to this type from the input type.

impl From<FanOut> for Composable

fn from(f: FanOut) -> Self

Converts to this type from the input type.

impl From<Loop> for Composable

fn from(l: Loop) -> Self

Converts to this type from the input type.

impl From<Pipeline> for Composable

fn from(p: Pipeline) -> Self

Converts to this type from the input type.

impl Mul<LoopPredicate> for Composable

Composable * until(pred) → conditional Loop

type Output = Composable

The resulting type after applying the * operator.

fn mul(self, rhs: LoopPredicate) -> Self::Output

Performs the * operation.

impl Mul<u32> for Composable

Composable * 3 → Loop(max=3)

type Output = Composable

The resulting type after applying the * operator.

fn mul(self, rhs: u32) -> Self::Output

Performs the * operation.

impl Shr<AgentBuilder> for Composable

Composable >> AgentBuilder → Pipeline (flattening)

type Output = Composable

The resulting type after applying the >> operator.

fn shr(self, rhs: AgentBuilder) -> Self::Output

Performs the >> operation.

impl Shr<Composable> for AgentBuilder

AgentBuilder >> Composable → Pipeline (flattening)

type Output = Composable

The resulting type after applying the >> operator.

fn shr(self, rhs: Composable) -> Self::Output

Performs the >> operation.

impl Shr for Composable

Composable >> Composable → Pipeline (flattening)

type Output = Composable

The resulting type after applying the >> operator.

fn shr(self, rhs: Composable) -> Self::Output

Performs the >> operation.