Skip to content

Commit 80b68c4

Browse files
committed
fix: silence abort error in http agent
1 parent b5269a2 commit 80b68c4

File tree

2 files changed

+12
-5
lines changed

2 files changed

+12
-5
lines changed

typescript-sdk/packages/client/src/run/http-request.ts

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -71,10 +71,6 @@ export const runHttpRequest = (url: string, requestInit: RequestInit): Observabl
7171
}
7272
subscriber.complete();
7373
} catch (error) {
74-
if ((error as DOMException)?.name === "AbortError") {
75-
subscriber.complete();
76-
return;
77-
}
7874
subscriber.error(error);
7975
}
8076
})();

typescript-sdk/packages/client/src/transform/http.ts

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@ import { HttpEvent, HttpEventType } from "../run/http-request";
44
import { parseSSEStream } from "./sse";
55
import { parseProtoStream } from "./proto";
66
import * as proto from "@ag-ui/proto";
7+
import { EventType } from "@ag-ui/core";
78

89
/**
910
* Transforms HTTP events into BaseEvents using the appropriate format parser based on content type.
@@ -47,7 +48,17 @@ export const transformHttpEventStream = (source$: Observable<HttpEvent>): Observ
4748
eventSubject.error(err);
4849
}
4950
},
50-
error: (err) => eventSubject.error(err),
51+
error: (err) => {
52+
if ((err as DOMException)?.name === "AbortError") {
53+
eventSubject.next({
54+
type: EventType.RUN_ERROR,
55+
rawEvent: err,
56+
});
57+
eventSubject.complete();
58+
return;
59+
}
60+
return eventSubject.error(err)
61+
},
5162
complete: () => eventSubject.complete(),
5263
});
5364
}

0 commit comments

Comments
 (0)