From 881d31231393c8adc15228ed2f842e1e862e701b Mon Sep 17 00:00:00 2001
From: guslegend <1670547022@qq.com>
Date: Sat, 23 May 2026 16:23:15 +0800
Subject: [PATCH 1/2] fix(agent): align EventType.ALL docs with stream behavior
---
.../src/main/java/io/agentscope/core/agent/EventType.java | 2 +-
.../main/java/io/agentscope/core/agent/StreamOptions.java | 3 ++-
.../java/io/agentscope/core/agent/StreamOptionsTest.java | 7 +++++++
docs/en/task/streaming.md | 6 +++---
docs/zh/task/streaming.md | 6 +++---
5 files changed, 16 insertions(+), 8 deletions(-)
diff --git a/agentscope-core/src/main/java/io/agentscope/core/agent/EventType.java b/agentscope-core/src/main/java/io/agentscope/core/agent/EventType.java
index 6cf59739c..7abcc104a 100644
--- a/agentscope-core/src/main/java/io/agentscope/core/agent/EventType.java
+++ b/agentscope-core/src/main/java/io/agentscope/core/agent/EventType.java
@@ -86,7 +86,7 @@ public enum EventType {
SUMMARY,
/**
- * Special value to stream all event types (except {@link #AGENT_RESULT}).
+ * Special value to stream all event types.
*
* Use this in {@link StreamOptions} to receive all events without filtering.
*/
diff --git a/agentscope-core/src/main/java/io/agentscope/core/agent/StreamOptions.java b/agentscope-core/src/main/java/io/agentscope/core/agent/StreamOptions.java
index 36a77db02..323b31bcd 100644
--- a/agentscope-core/src/main/java/io/agentscope/core/agent/StreamOptions.java
+++ b/agentscope-core/src/main/java/io/agentscope/core/agent/StreamOptions.java
@@ -140,7 +140,8 @@ public static Builder builder() {
/**
* Get the set of event types that should be streamed.
*
- *
If the set contains {@link EventType#ALL}, all event types will be streamed.
+ *
If the set contains {@link EventType#ALL}, all event types will be streamed,
+ * including {@link EventType#AGENT_RESULT}.
*
* @return The set of event types to stream
*/
diff --git a/agentscope-core/src/test/java/io/agentscope/core/agent/StreamOptionsTest.java b/agentscope-core/src/test/java/io/agentscope/core/agent/StreamOptionsTest.java
index 3c890c427..2a90adb8b 100644
--- a/agentscope-core/src/test/java/io/agentscope/core/agent/StreamOptionsTest.java
+++ b/agentscope-core/src/test/java/io/agentscope/core/agent/StreamOptionsTest.java
@@ -86,6 +86,13 @@ void testBuilderAllEventTypes() {
assertTrue(options.shouldStream(EventType.AGENT_RESULT));
}
+ @Test
+ void testAllMeansAllIncludingAgentResult() {
+ StreamOptions options = StreamOptions.builder().eventTypes(EventType.ALL).build();
+
+ assertTrue(options.shouldStream(EventType.AGENT_RESULT));
+ }
+
@Test
void testBuilderIncrementalMode() {
// Test incremental mode (true)
diff --git a/docs/en/task/streaming.md b/docs/en/task/streaming.md
index 3931b702d..d30c33757 100644
--- a/docs/en/task/streaming.md
+++ b/docs/en/task/streaming.md
@@ -43,8 +43,8 @@ Flux events = agent.stream(msgs, StreamOptions.defaults(), ctx);
| `TOOL_RESULT` | After each tool execution | `ToolResultBlock` (tool name, id, output) |
| `HINT` | After RAG / memory retrieval | Context text injected into the model |
| `SUMMARY` | When `maxIters` is reached | Iteration summary text |
-| `AGENT_RESULT` | Final reply ready | Same as `call()` return value; **not included** in stream by default |
-| `ALL` | Placeholder for all the above (except `AGENT_RESULT`) | — |
+| `AGENT_RESULT` | Final reply ready | Same as `call()` return value |
+| `ALL` | Placeholder for all event types | - |
### Subscribe to specific types only
@@ -153,7 +153,7 @@ serialize `event.getSource()` as well — see [Harness Subagent Streaming](../ha
```java
StreamOptions options = StreamOptions.builder()
- // Event types to receive (default: ALL, excluding AGENT_RESULT)
+ // Event types to receive (default: ALL)
.eventTypes(EventType.REASONING, EventType.TOOL_RESULT, EventType.AGENT_RESULT)
// Incremental mode: true = push deltas (default), false = push full accumulated text
diff --git a/docs/zh/task/streaming.md b/docs/zh/task/streaming.md
index aa23d71b9..686770eeb 100644
--- a/docs/zh/task/streaming.md
+++ b/docs/zh/task/streaming.md
@@ -43,8 +43,8 @@ Flux events = agent.stream(msgs, StreamOptions.defaults(), ctx);
| `TOOL_RESULT` | 每次工具执行完毕后 | `ToolResultBlock`（含工具名、id、输出） |
| `HINT` | RAG / 记忆检索注入后 | 注入模型的上下文文本 |
| `SUMMARY` | 达到 `maxIters` 上限时 | 迭代摘要文本 |
-| `AGENT_RESULT` | 最终回复就绪 | 与 `call()` 返回值相同，默认**不在**流中 |
-| `ALL` | 占位符，代表全部（不含 `AGENT_RESULT`） | — |
+| `AGENT_RESULT` | 最终回复就绪 | 与 `call()` 返回值相同 |
+| `ALL` | 占位符，代表全部事件类型 | - |
### 只订阅指定类型
@@ -151,7 +151,7 @@ public Flux> chat(@RequestParam String message) {
```java
StreamOptions options = StreamOptions.builder()
- // 订阅的事件类型（默认 ALL，不含 AGENT_RESULT）
+ // 订阅的事件类型（默认 ALL）
.eventTypes(EventType.REASONING, EventType.TOOL_RESULT, EventType.AGENT_RESULT)
// 增量模式（默认 true）
From 34926876662809235ad64922b055dacc62679b7f Mon Sep 17 00:00:00 2001
From: guslegend <1670547022@qq.com>
Date: Sat, 23 May 2026 19:17:30 +0800
Subject: [PATCH 2/2] fix(agent): align EventType.ALL docs with stream behavior
---
.../src/main/java/io/agentscope/core/agent/EventType.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/agentscope-core/src/main/java/io/agentscope/core/agent/EventType.java b/agentscope-core/src/main/java/io/agentscope/core/agent/EventType.java
index 7abcc104a..850639b0a 100644
--- a/agentscope-core/src/main/java/io/agentscope/core/agent/EventType.java
+++ b/agentscope-core/src/main/java/io/agentscope/core/agent/EventType.java
@@ -86,7 +86,7 @@ public enum EventType {
SUMMARY,
/**
- * Special value to stream all event types.
+ * Special value to stream all event types, including {@link #AGENT_RESULT}.
*
* Use this in {@link StreamOptions} to receive all events without filtering.
*/