Skip to content

Commit ea8187d

Browse files
committed
handle zodfetchSSE connection errors
1 parent ae7f5b4 commit ea8187d

File tree

2 files changed

+11
-0
lines changed

2 files changed

+11
-0
lines changed

packages/cli-v3/src/apiClient.ts

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -281,6 +281,13 @@ export class CliApiClient {
281281
},
282282
});
283283

284+
source.onConnectionError((error) => {
285+
rejectPromise({
286+
success: false,
287+
error,
288+
});
289+
});
290+
284291
source.onMessage("complete", (message) => {
285292
resolvePromise({
286293
success: true,

packages/core/src/v3/apiClient/core.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -655,6 +655,10 @@ export class ZodFetchSSEResult<TMessageCatalog extends ZodFetchSSEMessageCatalog
655655
});
656656
}
657657

658+
public onConnectionError(handler: (error: Event) => void) {
659+
this._eventSource.onerror = handler;
660+
}
661+
658662
public onMessage<T extends keyof TMessageCatalog>(
659663
type: T,
660664
handler: ZodFetchSSEMessageHandlers<TMessageCatalog>[T]

0 commit comments

Comments
 (0)