Agents StreamingFunc is ignored

[pkrauss-prot]

package version: github.com/tmc/langchaingo v0.1.12

Regardless of using the chains run or call the streamingFunc defined is ignored.

agent := agents.NewConversationalAgent(llm,
		agentTools,
		agents.WithMaxIterations(3),
	)
executor := agents.NewExecutor(agent)

question := "what is the answer for 1000092 / 23999 * 1000000? break it down into steps"
answer, err := chains.Run(context.Background(), executor, question, chains.WithStreamingFunc(func(ctx context.Context, chunk []byte) error {
	fmt.Printf("streaming: %s\n", string(chunk))
	return nil
}))

[XCapsule]

I encountered a similar issue, and I solved it with the following approach:

agent := agents.NewConversationalAgent(llm,
    agentTools,
    agents.WithMaxIterations(3),
    agents.WithCallbacksHandler(CustomHandler{}))
executor := agents.NewExecutor(agent)

question := "Who is Olivia Wilde's boyfriend? What is his current age raised to the 0.23 power?"
answer, err := chains.Run(context.Background(), executor, question)

In my solution, I created a custom CallbacksHandler and implemented the HandleStreamingFunc inside it. This ensures that the streaming data is processed correctly.