chore: reduction close copied tool output stream (#1008)

N3kox · web-flow · commit e5e2b182735a · 2026-05-07T20:12:26.000+08:00
diff --git a/adk/middlewares/reduction/reduction.go b/adk/middlewares/reduction/reduction.go
@@ -439,6 +439,7 @@ func (t *toolReductionMiddleware) WrapStreamableToolCall(_ context.Context, endp
 		}
 		truncResult, err := cfg.TruncHandler(ctx, detail)
 		if err != nil {
+			origResp.Close()
 			return nil, err
 		}
 		if !truncResult.NeedTrunc {
@@ -535,6 +536,7 @@ func (t *toolReductionMiddleware) WrapEnhancedStreamableToolCall(ctx context.Con
 		}
 		truncResult, err := cfg.TruncHandler(ctx, detail)
 		if err != nil {
+			origResp.Close()
 			return nil, err
 		}
 		if !truncResult.NeedTrunc {

Original file line number	Diff line number	Diff line change
`@@ -439,6 +439,7 @@ func (t *toolReductionMiddleware) WrapStreamableToolCall(_ context.Context, endp`
`439`	`439`	`}`
`440`	`440`	`truncResult, err := cfg.TruncHandler(ctx, detail)`
`441`	`441`	`if err != nil {`
	`442`	`+ origResp.Close()`
`442`	`443`	`return nil, err`
`443`	`444`	`}`
`444`	`445`	`if !truncResult.NeedTrunc {`
`@@ -535,6 +536,7 @@ func (t *toolReductionMiddleware) WrapEnhancedStreamableToolCall(ctx context.Con`
`535`	`536`	`}`
`536`	`537`	`truncResult, err := cfg.TruncHandler(ctx, detail)`
`537`	`538`	`if err != nil {`
	`539`	`+ origResp.Close()`
`538`	`540`	`return nil, err`
`539`	`541`	`}`
`540`	`542`	`if !truncResult.NeedTrunc {`