From 8adfe70c4454363bc839ca405657de91da01998b Mon Sep 17 00:00:00 2001
From: Kujtim Hoxha <kujtimii.h@gmail.com>
Date: Thu, 5 Feb 2026 14:06:24 +0100
Subject: [PATCH] fix: hyper provider cancel (#2133)

---
 internal/agent/hyper/provider.go | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/internal/agent/hyper/provider.go b/internal/agent/hyper/provider.go
index bba8542549827622baa0a47b40e39765e5dc9376..e4c1cd85eb1171226f48ff496ea238ff2121619d 100644
--- a/internal/agent/hyper/provider.go
+++ b/internal/agent/hyper/provider.go
@@ -252,10 +252,16 @@ func (m *languageModel) Stream(ctx context.Context, call fantasy.Call) (fantasy.
 				continue
 			}
 		}
-		if err := scanner.Err(); err != nil &&
-			!errors.Is(err, context.Canceled) &&
-			!errors.Is(err, context.DeadlineExceeded) {
-			yield(fantasy.StreamPart{Type: fantasy.StreamPartTypeError, Error: err})
+		if err := scanner.Err(); err != nil {
+			if sawFinish && (errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded)) {
+				// If we already saw an explicit finish event, treat cancellation as a no-op.
+			} else {
+				_ = yield(fantasy.StreamPart{Type: fantasy.StreamPartTypeError, Error: err})
+				return
+			}
+		}
+		if err := ctx.Err(); err != nil && !sawFinish {
+			_ = yield(fantasy.StreamPart{Type: fantasy.StreamPartTypeError, Error: err})
 			return
 		}
 		// flush any pending data