fix(stream): respect StreamOptions config for event emission (#411)

Author: AlbumenJ

agentscope-core/src/main/java/io/agentscope/core/agent/AgentBase.java

@@ -685,12 +685,14 @@ private Flux<Event> createEventStream(StreamOptions options, Supplier<Mono<Msg>>
                                             })
                                     .subscribe(
                                             finalMsg -> {
-                                                Event finalEvent =
-                                                        new Event(
-                                                                EventType.AGENT_RESULT,
-                                                                finalMsg,
-                                                                true);
-                                                sink.next(finalEvent);
+                                                if (options.shouldStream(EventType.AGENT_RESULT)) {
+                                                    Event finalEvent =
+                                                            new Event(
+                                                                    EventType.AGENT_RESULT,
+                                                                    finalMsg,
+                                                                    true);
+                                                    sink.next(finalEvent);
+                                                }
 
                                                 // Complete the stream
                                                 sink.complete();

agentscope-core/src/main/java/io/agentscope/core/agent/StreamingHook.java

@@ -63,14 +63,16 @@ public <T extends HookEvent> Mono<T> onEvent(T event) {
             PostReasoningEvent e = (PostReasoningEvent) event;
             // postReasoning is called after streaming completes
             // This is the last/complete message
-            if (options.shouldStream(EventType.REASONING)) {
+            if (options.shouldStream(EventType.REASONING)
+                    && options.shouldIncludeReasoningEmission(false)) {
                 emitEvent(EventType.REASONING, e.getReasoningMessage(), true);
             }
             return Mono.just(event);
         } else if (event instanceof ReasoningChunkEvent) {
             ReasoningChunkEvent e = (ReasoningChunkEvent) event;
             // This is an intermediate chunk
-            if (options.shouldStream(EventType.REASONING)) {
+            if (options.shouldStream(EventType.REASONING)
+                    && options.shouldIncludeReasoningEmission(true)) {
                 // Use incremental or accumulated based on StreamOptions
                 Msg msgToEmit =
                         options.isIncremental() ? e.getIncrementalChunk() : e.getAccumulated();