aboutsummaryrefslogtreecommitdiff
path: root/test/bun.js/streams.test.js
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-11-02 20:44:49 -0700
committerGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-11-02 20:44:49 -0700
commit09434f1486035c60016ded1359189dfdeed72e5d (patch)
treea043a4a9171708a7b6d4ea341328deb6a941bf4b /test/bun.js/streams.test.js
parent1a92b92f8a94fef5d40f9419d7897ab5ceb054cd (diff)
downloadbun-09434f1486035c60016ded1359189dfdeed72e5d.tar.gz
bun-09434f1486035c60016ded1359189dfdeed72e5d.tar.zst
bun-09434f1486035c60016ded1359189dfdeed72e5d.zip
Add failing test
Diffstat (limited to 'test/bun.js/streams.test.js')
-rw-r--r--test/bun.js/streams.test.js38
1 files changed, 36 insertions, 2 deletions
diff --git a/test/bun.js/streams.test.js b/test/bun.js/streams.test.js
index 6488eb37f..d18aae84a 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);