uni-flow 公开 API（中文注解）

---

uni-flow 公开 API（中文注解） / InMemoryMessageBus

Class: InMemoryMessageBus

Defined in: core/message-bus.ts:26

进程内消息总线：发布 / 订阅 / 历史查询，支持 at-least-once 或 exactly-once。 一般通过 createMessageBus 获取。

Implements

• MessageBus

Constructors

Constructor

new InMemoryMessageBus(deliveryGuarantee?): InMemoryMessageBus

Defined in: core/message-bus.ts:32

Parameters

deliveryGuarantee?

"at-least-once" | "exactly-once"

Returns

InMemoryMessageBus

Properties

deliveryGuarantee

readonly deliveryGuarantee: "at-least-once" | "exactly-once"

Defined in: core/message-bus.ts:27

投递保证语义。

Implementation of

MessageBus.deliveryGuarantee

Methods

history()

history(filter?): WorkflowMessage[]

Defined in: core/message-bus.ts:55

查询历史消息。

Parameters

filter?

Partial<{ since: number; sourceUnitId: string; targetUnitId: string; type: "delegation" | "unit-output" | "steering" | "followup" | "broadcast" | "state-update" | "checkpoint" | "policy-violation" | "hitl-request" | "hitl-response" | "cost-update"; until: number; }>

Returns

WorkflowMessage[]

Implementation of

MessageBus.history

---

publish()

publish(message): void

Defined in: core/message-bus.ts:36

异步派发消息（不阻塞调用方等待 handler）。

Parameters

message

WorkflowMessage

Returns

void

Implementation of

MessageBus.publish

---

publishSync()

publishSync(message): Promise<void>

Defined in: core/message-bus.ts:41

同步等待所有匹配 handler 完成。

Parameters

message

WorkflowMessage

Returns

Promise<void>

Implementation of

MessageBus.publishSync

---

subscribe()

subscribe(filter, handler): () => void

Defined in: core/message-bus.ts:46

按过滤条件订阅；返回取消函数。

Parameters

filter

MessageFilter

handler

MessageHandler

Returns

() => void

Implementation of

MessageBus.subscribe