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

test: clear ollama stream timeout guard

Browse Source
This commit is contained in:
Shakker
2026-05-09 01:01:04 +01:00
parent 105cc8d18a
commit c9e85fdbd6
1 changed files with 13 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
extensions/ollama/src/stream-runtime.test.ts
View File

@@ -1237,12 +1237,19 @@ async function nextEventWithin<T>(
iterator: AsyncIterator<T>,
timeoutMs = 100,
): Promise<IteratorResult<T> | "timeout"> {
return await Promise.race([
iterator.next(),
new Promise<"timeout">((resolve) => {
setTimeout(() => resolve("timeout"), timeoutMs);
}),
]);
let timer: NodeJS.Timeout | undefined;
try {
return await Promise.race([
iterator.next(),
new Promise<"timeout">((resolve) => {
timer = setTimeout(() => resolve("timeout"), timeoutMs);
}),
]);
} finally {
if (timer) {
clearTimeout(timer);
}
}
}
describe("createOllamaStreamFn streaming events", () => {