vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 17:20:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: stabilize anthropic stream abort smoke

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-02 17:46:51 +01:00
parent 25ca5cc8df
commit 06a5469f47
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/agents/anthropic-transport-stream.live.test.ts
View File

@@ -62,8 +62,17 @@ describeLive("anthropic transport stream live", () => {
const abortReason = new Error("live anthropic stream abort");
let requestBody = "";
let requestBodyPromise: Promise<string> | undefined;
let responseClosed = false;
let resolveResponseClosed: (() => void) | undefined;
const responseClosedPromise = new Promise<void>((resolve) => {
resolveResponseClosed = resolve;
});
const server = http.createServer((request, response) => {
response.on("close", () => {
responseClosed = true;
resolveResponseClosed?.();
});
requestBodyPromise = readRequestBody(request).then((body) => {
requestBody = body;
response.writeHead(200, {
@@ -109,9 +118,11 @@ describeLive("anthropic transport stream live", () => {
if (result === timedOut) {
throw new Error("Anthropic live SSE stream did not abort within 1000ms");
}
await Promise.race([responseClosedPromise, delay(1_000, undefined)]);
expect(result.stopReason).toBe("aborted");
expect(result.errorMessage).toBe("live anthropic stream abort");
expect(responseClosed).toBe(true);
const capturedRequestBody = requestBodyPromise
? await Promise.race([requestBodyPromise, delay(500, requestBody)])
: requestBody;