SessionEventPreviewBus
@Component public class SessionEventPreviewBus源码Source
io/agentscope/builder/web/managed/SessionEventPreviewBus.java:30–81会话事件预览总线，承载智能体的部署、调度与服务化运行。位于 io.agentscope.builder.web.managed 包。核心成员包括 emitStart、emitDelta、emitFrame、subscribe。
Process-local stream-only preview bus for event_start / event_delta. Never
persisted; best-effort and sticky to the turn-owner JVM (see DATA_PLANE_CONTRACT §3).
方法摘要Method Summary
| 方法Method | 说明Description |
|---|---|
public void emitStart(String sessionId, String targetType, String eventId) | 发出启动。 Emits an `event_start` frame for a forthcoming persisted type. |
public void emitDelta(String sessionId, String targetType, String eventId, String delta) | 发出增量。 Emits an `event_delta` frame. |
public void emitFrame(String sessionId, SessionEventMapper.PreviewFrame frame, Set<String> enabledTypes) | 发出 `emitFrame`。 Publishes a mapper preview frame when the subscriber opted into `targetType`. |
public Flux<SessionEventDto> subscribe(String sessionId) | 设置订阅。 Performs the subscribe operation. |
方法详情Method Detail
emitStart
public void emitStart(String sessionId, String targetType, String eventId)发出启动。
Emits an event_start frame for a forthcoming persisted type.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
sessionId | String | 会话标识（类型 `String`）。The session id. |
targetType | String | 目标类型（类型 `String`）。The target type. |
eventId | String | 事件标识（类型 `String`）。The event id. |
源码Source
io/agentscope/builder/web/managed/SessionEventPreviewBus.java:37–42emitDelta
public void emitDelta(String sessionId, String targetType, String eventId, String delta)发出增量。
Emits an event_delta frame.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
sessionId | String | 会话标识（类型 `String`）。The session id. |
targetType | String | 目标类型（类型 `String`）。The target type. |
eventId | String | 事件标识（类型 `String`）。The event id. |
delta | String | 增量（类型 `String`）。The delta. |
源码Source
io/agentscope/builder/web/managed/SessionEventPreviewBus.java:45–51emitFrame
public void emitFrame(String sessionId, SessionEventMapper.PreviewFrame frame, Set<String> enabledTypes)发出 emitFrame。
Publishes a mapper preview frame when the subscriber opted into targetType.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
sessionId | String | 会话标识（类型 `String`）。The session id. |
frame | SessionEventMapper.PreviewFrame | frame（类型 `SessionEventMapper.PreviewFrame`）。The frame. |
enabledTypes | Set<String> | 已启用类型（类型 `Set`）。The enabled types. |
源码Source
io/agentscope/builder/web/managed/SessionEventPreviewBus.java:54–64subscribe
public Flux<SessionEventDto> subscribe(String sessionId)设置订阅。
Performs the subscribe operation.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
sessionId | String | 会话标识（类型 `String`）。The session id. |
Flux<SessionEventDto>返回Flux。Returns flux.
源码Source
io/agentscope/builder/web/managed/SessionEventPreviewBus.java:66–68