Change summary
agent.go | 6 +++---
providers/anthropic.go | 2 +-
2 files changed, 4 insertions(+), 4 deletions(-)
Detailed changes
@@ -767,7 +767,7 @@ func (a *agent) Stream(ctx context.Context, opts AgentStreamCall) (*AgentResult,
// Start step stream
if opts.OnStepStart != nil {
- opts.OnStepStart(stepNumber)
+ _ = opts.OnStepStart(stepNumber)
}
// Create streaming call
@@ -808,7 +808,7 @@ func (a *agent) Stream(ctx context.Context, opts AgentStreamCall) (*AgentResult,
// Call step finished callback
if opts.OnStepFinish != nil {
- opts.OnStepFinish(stepResult)
+ _ = opts.OnStepFinish(stepResult)
}
// Add step messages to response messages
@@ -834,7 +834,7 @@ func (a *agent) Stream(ctx context.Context, opts AgentStreamCall) (*AgentResult,
}
if opts.OnAgentFinish != nil {
- opts.OnAgentFinish(agentResult)
+ _ = opts.OnAgentFinish(agentResult)
}
return agentResult, nil
@@ -775,7 +775,7 @@ func (a anthropicLanguageModel) Stream(ctx context.Context, call ai.Call) (ai.St
for stream.Next() {
chunk := stream.Current()
- acc.Accumulate(chunk)
+ _ = acc.Accumulate(chunk)
switch chunk.Type {
case "content_block_start":
contentBlockType := chunk.ContentBlock.Type