aboutsummaryrefslogtreecommitdiff
path: root/test/bun.js/node-stream-uint8array.test.ts
diff options
context:
space:
mode:
authorGravatar Ashcon Partovi <ashcon@partovi.net> 2023-03-07 12:22:34 -0800
committerGravatar GitHub <noreply@github.com> 2023-03-07 12:22:34 -0800
commitf7e4eb83694aa007a492ef66c28ffbe6a2dae791 (patch)
tree7af25aa5c42a2e1b2b47ba1df35f8caa9054cbeb /test/bun.js/node-stream-uint8array.test.ts
parent36275a44ce7a33587bd26aad120042ab95470ff3 (diff)
downloadbun-f7e4eb83694aa007a492ef66c28ffbe6a2dae791.tar.gz
bun-f7e4eb83694aa007a492ef66c28ffbe6a2dae791.tar.zst
bun-f7e4eb83694aa007a492ef66c28ffbe6a2dae791.zip
Reorganize tests (#2332)
Diffstat (limited to 'test/bun.js/node-stream-uint8array.test.ts')
-rw-r--r--test/bun.js/node-stream-uint8array.test.ts111
1 files changed, 0 insertions, 111 deletions
diff --git a/test/bun.js/node-stream-uint8array.test.ts b/test/bun.js/node-stream-uint8array.test.ts
deleted file mode 100644
index ec2e95d34..000000000
--- a/test/bun.js/node-stream-uint8array.test.ts
+++ /dev/null
@@ -1,111 +0,0 @@
-import { beforeEach, describe, expect, it } from "bun:test";
-import { Readable, Writable } from "stream";
-
-const ABC = new Uint8Array([0x41, 0x42, 0x43]);
-const DEF = new Uint8Array([0x44, 0x45, 0x46]);
-const GHI = new Uint8Array([0x47, 0x48, 0x49]);
-
-describe("Writable", () => {
- let called;
-
- function logCall(fn, id) {
- return function () {
- called[id] = (called[id] || 0) + 1;
- return fn.apply(this, arguments);
- };
- }
-
- beforeEach(() => {
- called = [];
- });
-
- it("should perform simple operations", () => {
- let n = 0;
- const writable = new Writable({
- write: logCall((chunk, encoding, cb) => {
- expect(chunk instanceof Buffer).toBe(true);
- if (n++ === 0) {
- expect(String(chunk)).toBe("ABC");
- } else {
- expect(String(chunk)).toBe("DEF");
- }
-
- cb();
- }, 0),
- });
-
- writable.write(ABC);
- writable.end(DEF);
- expect(called).toEqual([2]);
- });
-
- it("should pass in Uint8Array in object mode", () => {
- const writable = new Writable({
- objectMode: true,
- write: logCall((chunk, encoding, cb) => {
- expect(chunk instanceof Buffer).toBe(false);
- expect(chunk instanceof Uint8Array).toBe(true);
- expect(chunk).toStrictEqual(ABC);
- expect(encoding).toBe("utf8");
- cb();
- }, 0),
- });
-
- writable.end(ABC);
- expect(called).toEqual([1]);
- });
-
- it("should handle multiple writes carried out via writev()", () => {
- let callback;
-
- const writable = new Writable({
- write: logCall((chunk, encoding, cb) => {
- expect(chunk instanceof Buffer).toBe(true);
- expect(encoding).toBe("buffer");
- expect(String(chunk)).toBe("ABC");
- callback = cb;
- }, 0),
- writev: logCall((chunks, cb) => {
- expect(chunks.length).toBe(2);
- expect(chunks[0].encoding).toBe("buffer");
- expect(chunks[1].encoding).toBe("buffer");
- expect(chunks[0].chunk + chunks[1].chunk).toBe("DEFGHI");
- }, 1),
- });
-
- writable.write(ABC);
- writable.write(DEF);
- writable.end(GHI);
- callback();
- expect(called).toEqual([1, 1]);
- });
-});
-
-describe("Readable", () => {
- it("should perform simple operations", () => {
- const readable = new Readable({
- read() {},
- });
-
- readable.push(DEF);
- readable.unshift(ABC);
-
- const buf = readable.read();
- expect(buf instanceof Buffer).toBe(true);
- expect([...buf]).toEqual([...ABC, ...DEF]);
- });
-
- it("should work with setEncoding()", () => {
- const readable = new Readable({
- read() {},
- });
-
- readable.setEncoding("utf8");
-
- readable.push(DEF);
- readable.unshift(ABC);
-
- const out = readable.read();
- expect(out).toBe("ABCDEF");
- });
-});