Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/openstatusHQ/openstatus. 🫖 Status page with uptime monitoring & API monitoring as code 🫖 openstatus.dev
bun drizzle-orm monitoring monitoring-as-code nextjs observability on-call open-source shadcn-ui status-page statuspage synthetic-monitoring tinybird turso uptime uptime-checker uptime-monitor
Something went wrong. Try again.
2.7 kB · 89 lines
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990import { describe, expect, it } from "vitest";
import { iteratorToStream, yieldMany } from "./stream";
function delay<T>(ms: number, value: T) { return new Promise<T>((resolve) => setTimeout(() => resolve(value), ms));}
async function collect<T>(gen: AsyncGenerator<T>) { const out: T[] = []; for await (const v of gen) out.push(v); return out;}
describe("yieldMany", () => { it("yields values in settle order, not input order", async () => { const out = await collect( yieldMany([delay(30, "slow"), delay(0, "fast"), delay(15, "mid")]), ); expect(out).toEqual(["fast", "mid", "slow"]); });
it("keeps every value that settles in the same microtask batch", async () => { const out = await collect( yieldMany([1, 2, 3, 4, 5].map((n) => Promise.resolve(n))), ); expect(out.sort()).toEqual([1, 2, 3, 4, 5]); });
it("completes immediately for an empty list", async () => { expect(await collect(yieldMany([]))).toEqual([]); });
it("returns 'done' when exhausted", async () => { const gen = yieldMany([Promise.resolve(1)]); expect(await gen.next()).toEqual({ value: 1, done: false }); expect(await gen.next()).toEqual({ value: "done", done: true }); });
it("yields values settled before a rejection, then throws it", async () => { const out: string[] = []; const run = async () => { for await (const v of yieldMany([ delay(0, "a"), delay(10, "unused").then(() => Promise.reject(new Error("boom"))), ])) { out.push(v); } }; await expect(run()).rejects.toThrow("boom"); expect(out).toEqual(["a"]); });
it("surfaces only the first of simultaneous rejections", async () => { const gen = yieldMany([ Promise.reject(new Error("first")), Promise.reject(new Error("second")), ]); await expect(gen.next()).rejects.toThrow("first"); });});
describe("iteratorToStream", () => { it("enqueues every yielded value then closes", async () => { async function* gen() { yield "a"; yield "b"; } const chunks: unknown[] = []; for await (const chunk of iteratorToStream(gen())) chunks.push(chunk); expect(chunks).toEqual(["a", "b"]); });
it("errors the stream when the iterator throws", async () => { async function* gen() { yield "a"; throw new Error("broken"); } const reader = iteratorToStream(gen()).getReader(); const originalError = console.error; console.error = () => {}; try { expect(await reader.read()).toEqual({ value: "a", done: false }); await expect(reader.read()).rejects.toThrow("broken"); } finally { console.error = originalError; } });});