From 09434f1486035c60016ded1359189dfdeed72e5d Mon Sep 17 00:00:00 2001 From: Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> Date: Wed, 2 Nov 2022 20:44:49 -0700 Subject: [PATCH] Add failing test --- test/bun.js/streams.test.js | 38 +++++++++++++++++++++++++++++++++++-- 1 file changed, 36 insertions(+), 2 deletions(-) diff --git a/test/bun.js/streams.test.js b/test/bun.js/streams.test.js index 6488eb37f4..d18aae84a4 100644 --- a/test/bun.js/streams.test.js +++ b/test/bun.js/streams.test.js @@ -9,12 +9,46 @@ import { mkfifo } from "mkfifo"; import { unlinkSync, writeFileSync } from "node:fs"; import { join } from "node:path"; import { gc } from "./gc"; -new Uint8Array(); beforeEach(() => gc()); afterEach(() => gc()); -describe("ReadableStream.prototype.tee", async () => { +// This test hangs, TODO: fix it +// describe("WritableStream", () => { +// it("works", async () => { +// try { +// var chunks = []; +// var writable = new WritableStream({ +// write(chunk, controller) { +// chunks.push(chunk); +// }, +// close(er) { +// console.log("closed"); +// console.log(er); +// }, +// abort(reason) { +// console.log("aborted!"); +// console.log(reason); +// }, +// }); +// var writer = writable.getWriter(); + +// writer.write(new Uint8Array([1, 2, 3])); +// writer.write(new Uint8Array([4, 5, 6])); +// await writer.close(); + +// expect(JSON.stringify(Array.from(Buffer.concat(chunks)))).toBe( +// JSON.stringify([1, 2, 3, 4, 5, 6]) +// ); +// } catch (e) { +// console.log(e); +// console.log(e.stack); +// throw e; +// } +// }); +// }); + +describe("ReadableStream.prototype.tee", () => { it("class", () => { const [a, b] = new ReadableStream().tee(); expect(a instanceof ReadableStream).toBe(true);