diff options
author | 2022-12-28 03:43:39 -0800 | |
---|---|---|
committer | 2022-12-28 03:43:39 -0800 | |
commit | 3d60b870ee0d206d79eb4dda22dec7da55d91184 (patch) | |
tree | 3a1b3bf08cbfe2b1c044cd4e7e5cd56490c38ce5 /test | |
parent | 3ae23091c6f69dbf192b8ad89d208403661bd8c3 (diff) | |
download | bun-3d60b870ee0d206d79eb4dda22dec7da55d91184.tar.gz bun-3d60b870ee0d206d79eb4dda22dec7da55d91184.tar.zst bun-3d60b870ee0d206d79eb4dda22dec7da55d91184.zip |
Fix `ReadableStream.pipeTo`
Diffstat (limited to 'test')
-rw-r--r-- | test/bun.js/streams.test.js | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/test/bun.js/streams.test.js b/test/bun.js/streams.test.js index 577570221..ec803a9dd 100644 --- a/test/bun.js/streams.test.js +++ b/test/bun.js/streams.test.js @@ -48,6 +48,24 @@ describe("WritableStream", () => { throw e; } }); + + it("pipeTo", async () => { + const rs = new ReadableStream({ + start(controller) { + controller.enqueue("hello world"); + controller.close(); + }, + }); + + let received; + const ws = new WritableStream({ + write(chunk, controller) { + received = chunk; + }, + }); + await rs.pipeTo(ws); + expect(received).toBe("hello world"); + }); }); describe("ReadableStream.prototype.tee", () => { |