Struct CompiledSubgraph 

pub struct CompiledSubgraph<S: WorkflowState> {
    pub projector: Arc<dyn StateProjector<S>>,
    pub max_steps: usize,
}

编译后的 Subgraph 描述符 — 可存入 NodeKind。

类型参数

• S — 外层 State 类型（与 NodeKind 一致）

内容

• projector — 类型擦除的执行器（包含 Graph + Lens + Merge）
• max_steps — 最大执行步数

使用方式

NodeKind::Subgraph(CompiledSubgraph {
    projector: Arc::new(spec),  // SubgraphSpec implements StateProjector
    max_steps: 1000,
})

Fields

projector: Arc<dyn StateProjector<S>>

类型擦除的执行器

max_steps: usize

最大执行步数

Implementations

impl<S: WorkflowState> CompiledSubgraph<S>

pub fn new(projector: Arc<dyn StateProjector<S>>, max_steps: usize) -> Self

创建新的 CompiledSubgraph。

pub async fn execute( &self, outer: &mut S, stream: Option<Arc<dyn StreamSink>>, cancel: CancellationToken, ) -> Result<(), GraphError>

执行 Subgraph。

pub fn graph_name(&self) -> &str

内层 Graph 的名称。

pub fn node_count(&self) -> usize

内层 Graph 的节点数。

Trait Implementations

impl<S: Clone + WorkflowState> Clone for CompiledSubgraph<S>

fn clone(&self) -> CompiledSubgraph<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: WorkflowState> Debug for CompiledSubgraph<S>

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

Formats the value using the given formatter.