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..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 (except {@link #AGENT_RESULT}). + * Special value to stream all event types, including {@link #AGENT_RESULT}. * *
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