fix: Add throw error

M. Emin Cihangeri · M. Emin Cihangeri · commit 480bae96de45 · 2025-09-19T14:02:52.000+02:00
diff --git a/packages/core/src/stream/sse-stream.ts b/packages/core/src/stream/sse-stream.ts
@@ -61,6 +61,7 @@ export class SseStream<Item> implements AsyncIterable<Item> {
           return;
         }
         logger.error('Error while iterating over SSE stream:', e);
+        throw e;
       } finally {
         // Make sure that the controller is aborted if the stream was not fully consumed
         if (!done) {

Original file line number	Diff line number	Diff line change
`@@ -61,6 +61,7 @@ export class SseStream<Item> implements AsyncIterable<Item> {`
`61`	`61`	`return;`
`62`	`62`	`}`
`63`	`63`	`logger.error('Error while iterating over SSE stream:', e);`
	`64`	`+ throw e;`
`64`	`65`	`} finally {`
`65`	`66`	`// Make sure that the controller is aborted if the stream was not fully consumed`
`66`	`67`	`if (!done) {`