程序包 io.agentscope.core.pipeline

类 FanoutPipeline.Builder

java.lang.Object

io.agentscope.core.pipeline.FanoutPipeline.Builder

封闭类:

FanoutPipeline

public static class FanoutPipeline.Builder
extends Object

Builder for creating fanout pipelines with fluent API.

构造器概要

构造器

构造器	说明
Builder()

方法概要

修饰符和类型	方法	说明
FanoutPipeline.Builder	addAgent(AgentBase agent)	Add an agent to the pipeline.
FanoutPipeline.Builder	addAgents(List<AgentBase> agentList)	Add multiple agents to the pipeline.
FanoutPipeline	build()	Build the fanout pipeline.
FanoutPipeline.Builder	concurrent()	Enable concurrent execution (default).
FanoutPipeline.Builder	concurrent(boolean concurrent)	Set whether to enable concurrent execution.
FanoutPipeline.Builder	scheduler(reactor.core.scheduler.Scheduler scheduler)
FanoutPipeline.Builder	sequential()	Enable sequential execution.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

Builder

public Builder()

方法详细资料

addAgent

public FanoutPipeline.Builder addAgent(AgentBase agent)

Add an agent to the pipeline.

参数:

agent - Agent to add

返回:

This builder for method chaining

addAgents

public FanoutPipeline.Builder addAgents(List<AgentBase> agentList)

Add multiple agents to the pipeline.

参数:

agentList - List of agents to add

返回:

This builder for method chaining

concurrent

public FanoutPipeline.Builder concurrent(boolean concurrent)

Set whether to enable concurrent execution.

参数:

concurrent - True for concurrent execution, false for sequential

返回:

This builder for method chaining

scheduler

public FanoutPipeline.Builder scheduler(reactor.core.scheduler.Scheduler scheduler)

参数:

scheduler -

返回:

concurrent

public FanoutPipeline.Builder concurrent()

Enable concurrent execution (default).

返回:

This builder for method chaining

sequential

public FanoutPipeline.Builder sequential()

Enable sequential execution.

返回:

This builder for method chaining

build

public FanoutPipeline build()

Build the fanout pipeline.

返回:

Configured fanout pipeline